下载地址Kafka Eaglehttp://download.kafka-eagle.org/下载地址连接不稳定,可以多次尝试直到成功连接下载
1.解压安装包并重命名
tar -zxvf kafka-eagle-bin-3.0.1.tar.gz
查看到解压后包含一个安装包,再解压
tar -zxvf efak-web-3.0.1-bin.tar.gz
移至上级目录并重命名
mv efak-web-3.0.1 ../efak
2.配置环境变量
sudo vim /etc/profile
# 配置KAFKA_EAGLE环境变量
export KE_HOM=/export/server/efak
export PATH=$PATH:$KE_HOME/bin
source /etc/profile
3.修改配置文件
vim system-config.propertiesefak.zk.cluster.alias=cluster1
cluster1.zk.list=node1:2181,node2:2181,node3:2181/Kafka
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://node1:3306/kafkaEagle?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
efak.username=root
efak.password=1234
4.mysql中创建kafkaEagle库
mysql -u root -p1234
create database kafkaEagle
5. 开启JMX监控
vim $KAFKA_HOME/bin/kafka-server-start.sh
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-server -Xms2G -Xmx2G -XX:PermSize=128m -XX:+UseG1GC -XX:MaxGCPauseMillis=200 -XX:ParallelGCThreads=8 -XX:ConcGCThreads=5 -XX:InitiatingHeapOccupancyPercent=70"
export JMX_PORT="9999"
fi
分发到其它节点
xsync kafka-server-start.sh
关闭Kafka集群后重新启动
6.启动efak
ke.sh start
网页端输入网址http://192.168.173.200:8048/
输入账号admin
密码123456 登录
进入监控页面