kafkaManager监控 简单实用

kafka的一款监控工具，由雅虎开源。
此文档只配置了简单使用，如需其他功能参考github

0x00 编译

1. git clone https://github.com/yahoo/kafka-manager.git
2. cd kafka-manager && ./sbt clean dist
3. 编译之后目录：kafka-manager/target/universal/kafka-manager-1.3.3.17.zip
4. 在要部署的目录解压：unzip kafka-manager-1.3.3.17.zip

0x01 配置

vi conf/application.conf

主要配置，只配置了简单使用，如需其他功能参考github
kafka-manager.zkhosts="localhost:2181"

关闭对kafka的增删改功能
#application.features=["KMClusterManagerFeature","KMTopicManagerFeature","KMPreferredReplicaElectionFeature","KMReassignPartitionsFeature"]
application.features=[]

0x02 部署

启动脚本：
#!/bin/bash
nohup bin/kafka-manager -Dconfig.file=/home/y/kafkaManager/conf/application.conf -Dhttp.port=8181 >> started.log & 

停止脚本：
#!/bin/bash
PID=$(ps -ef|grep kafkaManager |grep -v grep |awk '{print $2}')
PID=${PID%"\n"}
if [ "${PID}" != "" ]; then
    echo "stopping  kafkaManager..."
    kill -9 $PID  && rm -f /home/y/kafka-manager-1.3.3.17/RUNNING_PID
    echo "kafkaManager is  stopped"
fi

0x03 使用监控

它有新建topic，修改kafka集群功能，为防止误操作，我将这些增删改功能关闭掉了，只用它查看集群。

1. 查看topic的状态，比如partition，ISR，consumer、生产速率等等
2. 查看broker的状态，比如jmx指标等等