下载Kafka-Eagle

官网下载：http://download.kafka-eagle.org/

百度网盘下载：

链接：https://pan.baidu.com/s/1QyxvimzaxmpO6tngHt6eeg 
提取码：kb1q 

1、解压Eagle

tar -zxvf kafka-eagle-bin-2.0.0.tar.gz
cd kafka-eagle-bin-2.0.0/
tar -zxvf kafka-eagle-web-2.0.0-bin.tar.gz -C /opt/modules/

eagle有两层压缩包

2、配置环境变量

# 1、重命名：
mv kafka-eagle-web-2.0.0/ eagle
# 2、配置环境变量：
sudo vi /etc/profile
# 3、添加如下信息：
# KE_HOME
export KE_HOME=/opt/modules/eagle
export PATH=$PATH:$KE_HOME/bin
# 4、使配置信息生效
source /etc/profile
# 5、验证是否设置成功：
echo $KE_HOME

3、修改配置文件

# 多个zookeeper和kafka群集列表
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=NODE1:2181,NODE2:2181,NODE3:2181
# broker size online 列表
cluster1.kafka.eagle.broker.size=20
# zk客户端线程限制
kafka.zk.limit.size=25
# kafka eagle webui页面端口
kafka.eagle.webui.port=8048
# kafka offset 存储
cluster1.kafka.eagle.offset.storage=kafka
# kafka metrics, 开启性能监控, 数据默认保留30天
kafka.eagle.metrics.charts=true
kafka.eagle.metrics.retain=15
# kafka sql topic主题 最大记录
kafka.eagle.sql.topic.records.max=5000
kafka.eagle.sql.fix.error=true
# delete kafka topic token
kafka.eagle.topic.token=keadmin
# kafka mysql jdbc 驱动程序地址
# Kafka-Eagle的表都是自动创建的，不需要使用者去操作
kafka.eagle.driver=com.mysql.jdbc.Driver
kafka.eagle.url=jdbc:mysql://xxx.xxx.xx.xx:3306/数据库名?characterEncoding=UTF-8&useUnicode=true&useSSL=false&tinyInt1isBit=false&allowPublicKeyRetrieval=true
kafka.eagle.username=root
kafka.eagle.password=密码

4、修改Kafka启动命令

修改 kafka-server-start.sh 命令中

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
fi

为

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"
#export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
fi

5、登录：

# 启动Kafka Eagle系统，执行如下命令：
ke.sh start
# 查看Kafka Eagle运行状态
ke.sh status
# 停止Kafka Eagle
ke.sh stop
# 查看Kafka Eagle GC情况
ke.sh gc
# 查看Kafka Eagle服务器资源占用情况，例如TCP、句柄等
ke.sh stats
# 查看Kafka Eagle版本号
ke.sh version
# 查看Kafka Eagle服务器上JDK的编码情况（如果JDK编码不是UTF-8，可能会有异常出现，执行如下命令，根据提示来修复JDK编码问题）
ke.sh jdk
# 查看Kafka Eagle中是否存在某个类（如果需要精确，类名前面可以加上包名）
ke.sh find [ClassName]

安装成功 

各模块的作用：（图片来源：https://blog.csdn.net/m0_46522455/article/details/108827979）