一、下载安装包

给kafka配一个web版的管理页面或仪表盘，管理起来更加方便

• 源码： https://github.com/smartloli/kafka-eagle/
• 官网：https://www.kafka-eagle.org/
• 下载： http://download.kafka-eagle.org/
• 安装文档： https://docs.kafka-eagle.org/2.env-and-install

直接下载kafka-eagle-bin-2.1.0.tar.gz链接：https://codeload.github.com/smartloli/kafka-eagle-bin/tar.gz/refs/tags/v2.1.0

二、安装

2.1 解压安装包

# 创建安装目录
mkdir -p /usr/local/kafka-eagle/
# 复制安装包到指定安装目录
cp kafka-eagle-bin-2.1.0.tar.gz /usr/local/kafka-eagle/
cd /usr/local/kafka-eagle/
# 解压
tar -zxvf kafka-eagle-bin-2.1.0.tar.gz
cd kafka-eagle-bin-2.1.0
# 解压
tar -zxvf efak-web-2.1.0-bin.tar.gz 

2.2 配置环境变量

2.2.1 设置Kafka-Eagle目录

vim /etc/profile
#Kafka_eagle
export KE_HOME=/usr/local/kafka-eagle/kafka-eagle-bin-2.1.0/efak-web-2.1.0
KE_PATH=$PATH:$KE_HOME/bin
export KE_PATH

2.2.2 更新环境变量

source /etc/profile

2.3 修改Kafka-Eagle配置文件

修改配置文件：

cd /usr/local/kafka-eagle/kafka-eagle-bin-2.1.0/efak-web-2.1.0/conf
vim system-config.properties

修改配置内容：

######################################
# multi zookeeper & kafka cluster list
# Settings prefixed with 'kafka.eagle.' will be deprecated, use 'efak.' instead
######################################
# zookeeper集群
efak.zk.cluster.alias=cluster1
cluster1.zk.list=192.168.252.160:2181

######################################
# kafka mysql jdbc driver address
######################################
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
efak.username=root
efak.password=123456

说明：

efak.url: 在启动kafka-eagle时候会自动执行脚本，创建相应的数据库

2.4 一切就绪后启动kafka-eagle

cd ../bin/
chmod +x ke.sh
./ke.sh start

启动成功打印日志如下：

如果出现错误，请查看日志日志是否出问题
tailf ../log/log.log

2.5 启动成功后，可直接登录

• http://host:8048/
• 默认用户名:admin
• 默认密码:12345

三、监控趋势图

Kafka系统默认是没有开启JMX端口的，所以Kafka Eagle的监控趋势图默认采用不启用的方式，即kafka.eagle.metrics.charts=false。如果需要查看监控趋势图，需要开启Kafka系统的JMX端口，设置该端口在$KAFKA_HOME/bin/kafka-server-start.sh脚本中，设置内容如下：

vim  /usr/local/kafka-eagle/kafka-eagle-bin-2.1.0/efak-web-2.1.0/conf/system-config.properties

######################################
# enable kafka metrics
######################################
kafka.eagle.metrics.charts=true
kafka.eagle.sql.fix.error=true

vi /opt/software/kafka/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"
    # 这里的端口不一定非要设置成9999，端口只要可用，均可。
    export JMX_PORT="9999" 
    #export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
fi

Kafka Eagle系统会自动获取这个JMX端口，采集结果如下：