kafka-eagle监控

kafka eagle（kafka鹰） 是一款由国内公司开源的Kafka集群监控系统，可以用来监视kafka集群的broker状态、Topic信息、IO、内存、consumer线程、偏移量等信息，并进行可视化图表展示。独特的KQL还可以通过SQL在线查询kafka中的数据。

mysql需要创建库：ke 用来储存元数据
库名可自定义，须与配置文件中的库名一样

官网下载安装包
https://www.kafka-eagle.org/

我的版本是kafka-eagle-bin-2.0.5.tar.gz、
解压安装包，解压后进入目录还有一个包需要解压
/opt/kafka-eagle-bin-2.0.5/kafka-eagle-web-2.0.5
编辑配置文件
vim /opt/kafka-eagle-bin-2.0.5/kafka-eagle-web-2.0.5/conf/system-config.properties
配置zk集群信息
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=192.168.10.13:2181,192.168.10.12:2182,192.168.10.12:2183
mysql数据库信息
kafka.eagle.driver=com.mysql.cj.jdbc.Driver
kafka.eagle.url=jdbc:mysql://192.168.10.13:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
kafka.eagle.username=root
kafka.eagle.password=qaz@Q123
保存退出

添加java、kafka-eagle环境变量 要不然启动会报错

vim /etc/profile
export KE_HOME=/opt/kafka-eagle-bin-2.0.5/kafka-eagle-web-2.0.5
export PATH=$PATH:$KE_HOME/bin
export JAVA_HOME=/opt/jdk1.8.0_231
export PATH=$PATH:$JAVA_HOME/bin
:wq
让配置生效
source /etc/profile

启动kafka-eagle
/opt/kafka-eagle-bin-2.0.5/kafka-eagle-web-2.0.5/bin/ke.sh start

访问ip:8048
默认用户密码：admin/123456


监控大屏功能

这里可以直接通过界面来创建topic

还有一个功能叫KSQL，可以通过SQL语句来查询Topic中的消息