zoukankan      html  css  js  c++  java
  • kafka-eagle部署

    1.环境准备

    主机名 IP地址 CPU 内存 硬盘
    gztxy-prd-kafka-eagle01 192.168.1.11 2 4 100G

    2.安装并配置

    安装:

    #下载kafka-eagle:
    https://codeload.github.com/smartloli/kafka-eagle-bin/tar.gz/v2.0.0
    tar -xf kafka-eagle-bin-2.0.0.tar.gz
    cd kafka-eagle-bin-2.0.0
    tar -xf kafka-eagle-web-2.0.0-bin.tar.gz -C /usr/local/
    ln -s /usr/local/kafka-eagle-web-2.0.0 /usr/local/kafka-eagle-web
    
    chmod +x /usr/local/kafka-eagle-web/bin/*
    
    添加环境变量:
    export KE_HOME=/usr/local/kafka-eagle-web
    export PATH=$PATH:$KE_HOME/bin
    export JAVA_HOME=/usr/local/jdk
    
    source /etc/profile
    

    配置:

    #集群名称
    kafka.eagle.zk.cluster.alias=cluster1,cluster2
    cluster1.zk.list=192.168.1.11:2181,192.168.1.12:2181,192.168.1.13:2181/kafka
    cluster2.zk.list=192.168.2.11:2181/kafka
    #开启使用图表
    kafka.eagle.metrics.charts=true
    kafka.eagle.sql.fix.error=true
    #sqlite数据库地址
    kafka.eagle.driver=org.sqlite.JDBC
    kafka.eagle.url=jdbc:sqlite:/usr/local/kafka-eagle-web/db/ke.db
    kafka.eagle.username=root
    kafka.eagle.password=smartloli
    #如果使用mysql数据库,可以配置以下配置
    kafka.eagle.driver=com.mysql.jdbc.Driver
    kafka.eagle.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
    kafka.eagle.username=root
    kafka.eagle.password=luchuangao
    ######################################
    # multi zookeeper&kafka cluster list
    ######################################
    kafka.eagle.zk.cluster.alias=cluster1
    #kafka.eagle.zk.cluster.alias=cluster1,cluster2
    cluster1.zk.list=192.168.1.12:2181
    #cluster1.zk.list=tdn1:2181,tdn2:2181,tdn3:2181
    #cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12: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
    cluster2.kafka.eagle.offset.storage=zk
    
    ######################################
    # enable kafka metrics
    ######################################
    kafka.eagle.metrics.charts=true
    kafka.eagle.sql.fix.error=true
    
    ######################################
    # 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:/usr/local/kafka-eagle-web/db/ke.db
    kafka.eagle.username=root
    kafka.eagle.password=smartloli
    完整的配置文件:system-config.properties

    启动:

    #vim kafka-eagle/bin/ke.sh
    ADMIN="Account:admin ,Password:123456"
    #启动
    ke.sh start
    #重启
    ke.sh restart
    

    3.访问

    http://192.168.1.11:8048

    炫酷的页面

  • 相关阅读:
    ORA-39126 KUPW$WORKER.PUT_DDLS [TABLE_STATISTICS]中Worker发生意外致命错误
    C# 9 新特性 —— 增强的 foreach
    在 xunit 测试项目中使用依赖注入
    gitee.com 码农中添加私有仓库并通过ssh链接
    强化学习 —— reinforce算法中更新一次策略网络时episodes个数的设置对算法性能的影响 —— reinforce算法中迭代训练一次神经网络时batch_size大小的不同设置对算法性能的影响
    如何在 Ubuntu18.04 server 服务器版本的操作系统下 配置IP
    东北某海滨城市的某高校的某分校区的校园网登录程序,(python3, 模拟浏览器的登入方式)
    强化学习中经典算法 —— reinforce算法 —— (进一步理解, 理论推导出的计算模型和实际应用中的计算模型的区别)
    【转载】 Linux 设置CPU Performance模式
    深度学习中使用TensorFlow或Pytorch框架时到底是应该使用CPU还是GPU来进行运算???
  • 原文地址:https://www.cnblogs.com/luchuangao/p/13453802.html
Copyright © 2011-2022 走看看