其他
Kafka三种可视化监控管理工具Monitor/Manager/Eagle
点击上方蓝色字体，选择“设为星标”
下载链接：https://github.com/Morningstar/kafka-offset-monitor/releases/tag/0.4.6上传jar包KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar到集群
在/opt/module/下创建kafka-offset-console文件夹
将上传的jar包放入刚创建的目录下
在/opt/module/kafka-offset-console目录下创建启动脚本start_en.sh，内容如下：
#!/bin/bash# 默认port为8086，由于我的环境8086端口已被占用，所有改为8087java -Xms512M -Xmx512M -Xss1024K -XX:MetaspaceSize=256m -XX:MaxMetaspaceSize=512m -cp KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar \com.quantifind.kafka.offsetapp.OffsetGetterWeb \--offsetStorage kafka \--kafkaBrokers cm1:9092,cm2:9092,cm3:9092 \--kafkaSecurityProtocol PLAINTEXT \--zk cm1:2181,cm2:2181,cm3:2181 \--port 8087 \--refresh 10.seconds \--retain 2.days \--dbName offsetapp_kafka 1>mobile-logs/stdout.log 2>mobile-logs/stderr.log &在/opt/module/kafka-offset-console目录下创建mobile-logs文件夹
mkdir /opt/module/kafka-offset-console/mobile-logs启动KafkaMonitor
./start_en.sh登录页面cm1:8087端口查看详情
2.Kafka Manager
2.1 部署
https://github.com/yahoo/kafka-manager/archive/1.3.3.15.zip
上传压缩包kafka-manager-1.3.3.15.zip到集群
解压kafka-manager-1.3.3.15.zip
$ unzip kafka-manager-1.3.3.15.zip修改kafka-manager-1.3.3.21/conf/application.conf文件启用Kafka-Manager使用账号登录
# 修改为：kafka-manager.zkhosts="cm1:2181,cm2:2181,cm3:2181"basicAuthentication.enabled=truebasicAuthentication.enabled=${?KAFKA_MANAGER_AUTH_ENABLED}basicAuthentication.username="admin"basicAuthentication.username=${?KAFKA_MANAGER_USERNAME}basicAuthentication.password="admin"basicAuthentication.password=${?KAFKA_MANAGER_PASSWORD}basicAuthentication.realm="Kafka-Manager"使用如下命令启动Kafka-Manager
[root@cm1 bin]$ chmod 777 kafka-manager# 默认为9000，但是我的集群有端口冲突，改为8090[root@cm1 kafka-manager-1.3.3.15]$ nohup bin/kafka-manager -Dhttp.port=8090 > nohup.out 2>&1 &在浏览器输入http://cm1:8090访问即可
登录Kafka-Manager管理界面
3.Kafka Eagle
参考 https://blog.csdn.net/qq_19524879/article/details/82848797
从git上下载:https://github.com/smartloli/kafka-eagle-bin/archive/v1.4.8.tar.gz（本例选择1.2.9版本）
解压（需要解压两次）
cd /opt/module/tar -zxf kafka-eagle-bin-1.4.8.tar.gzcd kafka-eagle-bin-1.4.8tar -zxf kafka-eagle-web-1.4.8-bin.tar.gzexport JAVA_HOME=/usr/java/jdk1.8.0_131-clouderaexport KE_HOME=/opt/module/kafka-eagle-bin-1.4.8/kafka-eagle-web-1.4.8export PATH=$JAVA_HOME/bin:$KE_HOME/bin:$PATHcd /opt/module/kafka-eagle-bin-1.4.8/kafka-eagle-web-1.4.8
# 修改为以下内容
#设置kafka集群（可以多个）kafka.eagle.zk.cluster.alias=cluster1cluster1.zk.list=cm1:2181,cm2:2181,cm3:2181
####################################### kafka eagle 的端口######################################kafka.eagle.webui.port=8048
####################################### kafka jdbc 地址注意可以自己安装数据mysql也可以自带的######################################kafka.eagle.driver=org.sqlite.JDBCkafka.eagle.url=jdbc:sqlite:/opt/module/kafka-eagle-bin-1.4.8/kafka-eagle-web-1.4.8/db/ke.dbkafka.eagle.username=rootkafka.eagle.password=123456#进入bin目录后会看到 ke.sh 文件先修改文件的权限chomd 777 ke.sh
ke.sh start# 停止ke.sh stop下面介绍下他的页面功能
文章不错？点个【在看】吧！ 👇