下载地址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/Kafkaefak.driver=com.mysql.cj.jdbc.Driverefak.url=jdbc:mysql://node1:3306/kafkaEagle?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNullefak.username=rootefak.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" ]; thenexport 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 登录

进入监控页面