1. 程式人生 > 實用技巧 >kafka-eagle部署

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

炫酷的頁面