版本抉择
v2.0.6
下载地址
https://codeload.github.com/s...
部署细节
因为kafka-eagle用的是jmx拉取数据,所以须要批改kafka启动脚本。vim kafka-server-start.sh
28 if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then 29 export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" 30 fi
改为
28 if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then 29 export KAFKA_HEAP_OPTS="-server -Xms2G -Xmx2G -XX:PermSize=128m -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:ParallelGCThreads=8 -XX:ConcGCThreads=5 -XX:InitiatingHeapOccupancyPercent=70" 30 export JMX_PORT="9999" 31 #export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" 32 fi
解压,kafka-eagle是嵌套的压缩。须要解压两次能力失去真正的安装包。
tar -zxvf kafka-eagle-bin-2.0.6.tar.gzcd kafka-eagle-bin-2.0.6tar -zxvf kafka-eagle-web-2.0.6-bin.tar.gz
kafka-eagle必须配置环境变量。
vim /etc/profileexport KE_HOME=/usr/local/kafka-eagle-web-2.0.6export PATH=$PATH:$KE_HOME/bin
批改配置文件:system-config.properties
个别须要批改的配置项都在上面了。
####################################### multi zookeeper & kafka cluster list######################################kafka.eagle.zk.cluster.alias=cluster1cluster1.zk.list=192.168.1.73:2181,192.168.1.52:2181,192.168.1.102:2181####################################### kafka offset storage######################################cluster1.kafka.eagle.offset.storage=kafka####################################### kafka mysql jdbc driver address######################################kafka.eagle.driver=com.mysql.cj.jdbc.Driverkafka.eagle.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNullkafka.eagle.username=rootkafka.eagle.password=123456
留神启动日志里的用户名明码
常用命令
启动:ke start
进行:ke stop
查看状态:ke status