安装kafka eagle监控kafka集群

1、下载kafka eagle的压缩包并解压

wget https://github.com/smartloli/kafka-eagle-bin/archive/v1.2.7.tar.gz

解压

tar -zxvf xxx

2、配置环境变量

需要配置JAVA_HOME和KE_HOME的环境变量

在自己的home目录下面的.bash_profile文件里面增加如下内容

export JAVA_HOME=/usr/local/jdk1.8.0_151
#add kafka-eagle
export KE_HOME=/data/ai-system/docker-data/kafka-eagle/kafka-eagle-bin-1.2.7/kafka-eagle-web-1.2.7
PATH=$PATH:$KE_HOME/bin:$JAVA_HOME/bin
export PATH

刷新使之立即生效

source ~/.bash_profile

这里有一定要将JAVA_HOME和KE_HOME export出来，不然后面运行会报错，因为ke.sh里面用到了这两个变量

3、修改配置文件

进入自己安装的kafka eagle的config目录

cd $KE_HOME/conf
vim system-config.properties

######################################
# multi zookeeper&kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1
#配置zk集群的
cluster1.zk.list=ip1:2181,ip2:2182,ip3:2183
#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181

######################################
# zk client thread limit
######################################
kafka.zk.limit.size=25

######################################
# kafka eagle webui port
######################################
访问web的端口，注意防火墙
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=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=true
kafka.eagle.mail.sa=alert_sa
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

######################################
# delete kafka topic token
######################################
kafka.eagle.topic.token=keadmin

######################################
# kafka sasl authenticate
######################################
kafka.eagle.sasl.enable=false
kafka.eagle.sasl.protocol=SASL_PLAINTEXT
kafka.eagle.sasl.mechanism=PLAIN

######################################
# kafka jdbc driver address
######################################
#我切换了自己mysql,下面用自己的配置的mysql的用户名和密码
kafka.eagle.driver=com.mysql.jdbc.Driver
kafka.eagle.url=jdbc:mysql://mysql_ip:3306/vision_platform?useUnicode: true&amp;characterEncoding: UTF-8
kafka.eagle.username=root
kafka.eagle.password=mysqlpasswd

开启ke.sh的可执行权限

chmod + x $KE_HOME/bin/ke.sh

4、运行ke.sh

命令	说明
ke.sh start	启动Kafka Eagle系统
ke.sh stop	停止Kafka Eagle系统
ke.sh restart	重启Kafka Eagle系统
ke.sh status	查看Kafka Eagle系统运行状态
ke.sh stats	统计Kafka Eagle系统占用Linux资源情况
ke.sh find [ClassName]	查看Kafka Eagle系统中的类是否存在