EFAK(原Kafka-Eagle)V2.1.0部署_猫与老者丶

irpas 02-07 2795

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数据库密码

启动成功后控制台会打印出用户名密码和HTTP访问地址相关信息。启动失败也会打印出这些信息，要通过链接访问成功和查看log日志才可确认是否存在问题。至此efak应可顺利进入仪表盘，但页面可能会存在错误。

5.页面错误修复

页面部分信息无法获取，日志中出现JMX之类error信息。官方解决办法： http://·mands.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