參考 ： kafka管理器kafka-manager部署安裝
下載Kafka Manager，並進行打包，由於Kafka manager是由scala寫的，所以需要由sbt的支持
git clone https://github.com/yahoo/kafka-manager cd kafka-manager ./sbt clean dist
關於sbt的的安裝，請移步
http://www.cnblogs.com/tonglin0325/p/8884470.html
配置zk的地址
在conf/application.conf中將kafka-manager.zkhosts的值設置為localhost
打包完成后，對kafka-manager-1.3.3.17.zip包進行解壓，位置在
kafka-manager/target/universal
修改配置
vim kafka-manager-1.3.3.17/conf/application.conf
啟動Kafka manager
bin/kafka-manager -Dconfig.file=/home/lintong/software/kafka-manager-1.3.3.17/conf/application.conf -Dhttp.port=7778
訪問
http://localhost:9000
然后在cluster中add cluster，比如
啟動后如果遇到
[warn] o.a.k.c.p.Errors - Unexpected error code: 38.
[warn] o.a.k.c.NetworkClient - Error while fetching metadata with correlation id 98 : {__consumer_offsets=UNKNOWN}
就手動創建一個叫__consumer_offsets的topic
如果你的kafka只有一台機器,然后遇到kafka-console-consumer無法消費的情況,可以查看一下offsets.topic.replication.factor這個參數是否為1,不是1的話消費者的offset是無法提交上去的
啟動Kafka的JMX，只需要修改kafka的啟動命令就行，注意給kafka添加jmx需要在kafka manager之前
啟動kafka服務時指定JMX_PORT值:
JMX_PORT=9999 bin/kafka-server-start.sh -daemon config/server.properties //一台機器部署多個server采用此方法
或者修改kafka-server-start.sh，在前面加上：
export JMX_PORT=9999 //如果一台機器部署一個server 建議采用此方法
點擊please enable consumer plooing here，配置查看消費者信息
關於Kafka Manager中的一些參數說明：
Topic 指標
Replication （副本數）
Number of Partitions (分區數)
Sum of partition offsets (offset大小，需要開啟JMX支持）
Total number of Brokers （Broker總數）
Number of Brokers for Topic （Topic所占Broker數）
Preferred Replicas % （）
Brokers Skewed % （Broker 均衡率）
Brokers Spread % （Broker 擴散率）
Under-replicated % （處於同步狀態的比率）
Metrics 指標
Message in /sec 消息數據流量
Bytes in /sec kafka輸入數據流量
Bytes out /sec kafka輸出數據流量
Bytes rejected /sec 拒絕的流量
Failed fetch request /sec 失敗的獲取請求
Failed produce request /sec 失敗的生產請求