Kafka三种可视化监控管理工具Monitor/Manager/Eagle

下载链接：https://github.com/Morningstar/kafka-offset-monitor/releases/tag/0.4.6

#!/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 &

mkdir /opt/module/kafka-offset-console/mobile-logs

./start_en.sh

$ unzip kafka-manager-1.3.3.15.zip

# 修改为：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"

[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 &