一、前言

??EFAK（(Eagle For Apache Kafka，以前稱為Kafka Eagle）用于在使用 Topic 的情況下監(jiān)控 Kafka 集群。包含Offset 的產(chǎn)生、Lag的變化、Partition的分布、Owner、Topic的創(chuàng)建以及修改的時(shí)間等信息。

二、環(huán)境&安裝包

• 官方下載連接EFAK (Eagle For Apache Kafka?) 3.0.1
• CentOS Linux release 7.9.2009 (Core)
• Kafka2.6.3
• Zookeeper3.7.0

三、部署&配置

Kafka、 Zookeeper部署這里就不多做教學(xué)了

1.kafka配置

kafka需要注意的配置：打開JMX PORT（編輯啟動(dòng)腳本添加該參數(shù)）

vim bin/kafka-server-start.sh
...
export JMX_PORT="9988" #端口隨意
...

2.zookeeper配置

zookeeper需要注意的配置：打開zkcli權(quán)限（zookeeper版本>=3.5）

vim bin/zkServer.sh 
...
# zookeeper enable client commands
ZOOMAIN="-Dzookeeper.4lw.commands.whitelist=* ${ZOOMAIN}"
...

具體修改如圖：

在啟動(dòng)參數(shù)里加一項(xiàng)就可，不是替換全部參數(shù)！！！
啟動(dòng)順序：Zookeeper -> Kafka

3.EFAK部署

tar -xvf kafka-eagle-bin-3.0.1.tar.gz
cd kafka-eagle-bin-3.0.1/
tar -xvf efak-web-3.0.1-bin.tar.gz
cd efak-web-3.0.1
vim conf/system-config.properties
...
efak.zk.cluster.alias=cluster1
cluster1.zk.list=192.168.200.39:2181
...
efak.driver=com.mysql.cj.jdbc.Driver
efak.url=jdbc:mysql://xx.xx.xx.xx:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
efak.username=root
efak.password=xxxx

xxx替換成自己服務(wù)器具體信息
注意：數(shù)據(jù)庫(kù)不需要?jiǎng)?chuàng)建，連接信息寫對(duì)、權(quán)限給足 服務(wù)會(huì)自己創(chuàng)建ke數(shù)據(jù)庫(kù)和table

3.1配置EFAK環(huán)境變量

vim /etc/profile
...
# EFAK變量
export KE_HOME=/srv/program/kafka-eagle-bin-3.0.1/efak-web-3.0.1
export PATH=$PATH:$KE_HOME/bin
# JAVA變量（必須配置，提前安裝好環(huán)境）
export JAVA_HOME=/srv/program/jdk1.8.0_181
...
:wq
# 啟動(dòng)EFAK（已經(jīng)啟動(dòng)Zookeeper和Kafka）
./bin/ke.sh start

四、使用&展示

官方使用手冊(cè)：【EFAK-document】

1.儀表板

2.kafka節(jié)點(diǎn)信息

3.zookeeper節(jié)點(diǎn)信息

4.監(jiān)控指標(biāo)

5.Kafka元數(shù)據(jù)

6.KSQL使用

7.平衡

8.報(bào)警

五、結(jié)束語(yǔ)

??到此EFAK監(jiān)控服務(wù)就部署完畢啦，如果有其它問題歡迎大家評(píng)論留言，如果覺得還可以，那么給作者點(diǎn)贊、收藏、關(guān)注吧！