EFAK V2.1.0部署

提示：原Kafka-eagle已于V2.0.7更名为EFAK

---

前言

新版EFAK部署需要sqlite或者MySQL(8.0以上）。使用低版本可能会导致efak无法连接数据库。

---

一、EFAK是什么？

EFAK（Eagle For Apache Kafka）是一个简单、高性能的Kafka集群监控系统，实现了监控、可视化操作Topic/Zookeeper、SQL查询、告警等功能。

二、安装步骤

1.下载

官网下载，提供历史版本下载：
官网下载地址

2.解压安装

tar -xzvf kafka-eagle-bin-2.1.0.tar.gz
cd kafka-eagle-bin-2.1.0
tar -xzvf efak-web-2.1.0-bin.tar.gz -C /usr/local
mv efak-web-2.1.0 kafka-eagle/

vim /etc/profile,添加下面环境变量：

export KE_HOME=/usr/local/kafka-eagle
export PATH=$KE_HOME/bin:$PATH

source /etc/profile

3.修改配置文件

cd /usr/local/kafka-eagle/conf
cp system-config.properties system-config.properties_bak

vim system-config.properties(下列为需要修改项，其余可保持默认。如只有一个集群注释掉所有cluster2项)

efak.zk.cluster.alias=cluster1 #Kafka使用的Zookeeper集群别名，多个集群用逗号分隔。
cluster1.zk.list=x.x.x.x:2181,x.x.x.x:2181,x.x.x.x:2181 #zookeeper.connect地址
cluster1.efak.offset.storage=kafka #存储消费信息的类型，一般在0.9版本之前，消费信息会默认存储在Zookeeper中，在0.10版本之后，消费者信息默认存储在 Kafka中，存储类型需要设置为kafka。
efak.metrics.retain=15 #性能监控数据保存天数
efak.driver=com.mysql.cj.jdbc.Driver #链接mysql8.0驱动，低版本数据库需修改
efak.username= #mysql数据库用户名
efak.password= #mysql数据库密码

---

4.启动验证

cd /usr/local/kafka-eagle/bin
./ke.sh start
./ke.sh start|status|stop|restart|stats #对应启动|服务状态|停止|重启|查看资源占用

启动成功后控制台会打印出用户名密码和HTTP访问地址相关信息。启动失败也会打印出这些信息，要通过链接访问成功和查看log日志才可确认是否存在问题。

至此efak应可顺利进入仪表盘，但页面可能会存在错误。

5.页面错误修复

页面部分信息无法获取，日志中出现JMX之类error信息。

官方解决办法：
http://www.kafka-eagle.org/articles/docs/quickstart/metrics.html

一、修改zookeeper配置
cd zookeeper/bin目录下
vi zkServer.sh
在77行后加入如下内容（不需要做修改）

// 加入77行之后
ZOOMAIN="-Dzookeeper.4lw.commands.whitelist=* ${ZOOMAIN}"

二、修改Kafka配置

cd Kafka/bin目录下
vi 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"
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"
fi

三、重启zookeeper
四、重启kafka
五、重启EFAK

总结

EFAK为国内软件，官方技术支持可中文沟通，如有奇怪报错可咨询官方~
官方邮箱联系方式： smartloli.org@gmail.com
QQ/WeChat : 810371213
QQ Group (Kafka): 825943084