Kafka Eagle安装

  • 解压压缩包

    tar -zxf kafka-eagle-bin-1.2.4.tar.gz
    
  • 设置全局变量,设置JDK的全局变量JAVA_HOME和本应用的KE_HOME

    
    export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.282.b08-1.el7_9.x86_64
    export KE_HOME=/root/eagle
    export PATH=$PATH:$KE_HOME/bin:$JAVA_HOME/bin
    
    
  • 进入kafka-eagle的conf目录下修改配置文件,配置基础配置

    ######################################
    # multi zookeeper&kafka cluster list
    ######################################
    kafka.eagle.zk.cluster.alias=cluster1
    cluster1.zk.list=192.168.1.146:2181
    
    ######################################
    # zk client thread limit
    ######################################
    kafka.zk.limit.size=25
    
    ######################################
    # kafka eagle webui port
    ######################################
    kafka.eagle.webui.port=8048
    
    ######################################
    # kafka offset storage
    ######################################
    cluster1.kafka.eagle.offset.storage=kafka
    
    ######################################
    # enable kafka metrics
    ######################################
    kafka.eagle.metrics.charts=false
    kafka.eagle.sql.fix.error=false
    
    ######################################
    # kafka sql topic records max
    ######################################
    kafka.eagle.sql.topic.records.max=5000
    
    ######################################
    # alarm email configure
    ######################################
    kafka.eagle.mail.enable=false
    kafka.eagle.mail.sa=alert_sa@163.com
    kafka.eagle.mail.username=alert_sa@163.com
    kafka.eagle.mail.password=mqslimczkdqabbbh
    kafka.eagle.mail.server.host=smtp.163.com
    kafka.eagle.mail.server.port=25
    
    ######################################
    # alarm im configure
    ######################################
    #kafka.eagle.im.dingding.enable=true
    #kafka.eagle.im.dingding.url=https://oapi.dingtalk.com/robot/send?access_token=
    
    #kafka.eagle.im.wechat.enable=true
    #kafka.eagle.im.wechat.token=https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=xxx&corpsecret=xxx
    #kafka.eagle.im.wechat.url=https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=
    #kafka.eagle.im.wechat.touser=
    #kafka.eagle.im.wechat.toparty=
    #kafka.eagle.im.wechat.totag=
    #kafka.eagle.im.wechat.agentid=
    
    ######################################
    # delete kafka topic token
    ######################################
    kafka.eagle.topic.token=keadmin
    
    ######################################
    # kafka sasl authenticate
    ######################################
    cluster1.kafka.eagle.sasl.enable=false
    cluster1.kafka.eagle.sasl.protocol=SASL_PLAINTEXT
    cluster1.kafka.eagle.sasl.mechanism=PLAIN
    cluster2.kafka.eagle.sasl.enable=false
    cluster2.kafka.eagle.sasl.protocol=SASL_PLAINTEXT
    cluster2.kafka.eagle.sasl.mechanism=PLAIN
    
    ######################################
    # kafka jdbc driver address
    ######################################
    kafka.eagle.driver=org.sqlite.JDBC
    kafka.eagle.url=jdbc:sqlite:/root/eagle/db/ke.db
    kafka.eagle.username=root
    kafka.eagle.password=root
    
    
  • 文件配置完毕后开始启动 ,启动要进入bin目录下

    #进入bin目录后会看到 ke.sh 文件先修改文件的权限
    sudo chmd777 ke.sh
    #启动命令
    ./ke.sh start
    
  • 启动成功后的控制台输出

Kafka Eagle安装

上一篇:PHP 将网页转图片


下一篇:Python 旋转目录中所有图片并保存