注册网站能赚钱吗,万能推广app,专业做网站优化需要多久,什么叫电商一、前言 EFAK#xff08;(Eagle For Apache Kafka#xff0c;以前称为Kafka Eagle#xff09;用于在使用 Topic 的情况下监控 Kafka 集群。包含Offset 的产生、Lag的变化、Partition的分布、Owner、Topic的创建以及修改的时间等信息。
二、环境安装包
官方下载连接E…一、前言 EFAK(Eagle For Apache Kafka以前称为Kafka Eagle用于在使用 Topic 的情况下监控 Kafka 集群。包含Offset 的产生、Lag的变化、Partition的分布、Owner、Topic的创建以及修改的时间等信息。
二、环境安装包
官方下载连接EFAK (Eagle For Apache Kafka®) 3.0.1 CentOS Linux release 7.9.2009 (Core)Kafka2.6.3Zookeeper3.7.0
三、部署配置 Kafka、 Zookeeper部署这里就不多做教学了 1.kafka配置 kafka需要注意的配置打开JMX PORT编辑启动脚本添加该参数 vim bin/kafka-server-start.sh
...
export JMX_PORT9988 #端口随意
...2.zookeeper配置 zookeeper需要注意的配置打开zkcli权限zookeeper版本3.5 vim bin/zkServer.sh
...
# zookeeper enable client commands
ZOOMAIN-Dzookeeper.4lw.commands.whitelist* ${ZOOMAIN}
...具体修改如图 在启动参数里加一项就可不是替换全部参数 启动顺序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.aliascluster1
cluster1.zk.list192.168.200.39:2181
...
efak.drivercom.mysql.cj.jdbc.Driver
efak.urljdbc:mysql://xx.xx.xx.xx:3306/ke?useUnicodetruecharacterEncodingUTF-8zeroDateTimeBehaviorconvertToNull
efak.usernameroot
efak.passwordxxxxxxx替换成自己服务器具体信息 注意数据库不需要创建连接信息写对、权限给足 服务会自己创建ke数据库和table 3.1配置EFAK环境变量
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变量必须配置提前安装好环境
export JAVA_HOME/srv/program/jdk1.8.0_181
...
:wq
# 启动EFAK已经启动Zookeeper和Kafka
./bin/ke.sh start四、使用展示 官方使用手册【EFAK-document】 1.仪表板 2.kafka节点信息 3.zookeeper节点信息 4.监控指标 5.Kafka元数据 6.KSQL使用 7.平衡 8.报警 五、结束语 到此EFAK监控服务就部署完毕啦如果有其它问题欢迎大家评论留言如果觉得还可以那么给作者点赞、收藏、关注吧
