Ubuntu下安装Kafka Manager

参考 : kafka管理器kafka-manager部署安装html

 

下载Kafka Manager,并进行打包,因为Kafka manager是由scala写的,因此须要由sbt的支持git

git clone https://github.com/yahoo/kafka-manager
cd kafka-manager
./sbt clean dist

 关于sbt的的安装,请移步github

http://www.cnblogs.com/tonglin0325/p/8884470.html

 配置zk的地址vim

在conf/application.conf中将kafka-manager.zkhosts的值设置为localhost

 打包完成后,对kafka-manager-1.3.3.17.zip包进行解压,位置在bash

kafka-manager/target/universal

 修改配置app

vim kafka-manager-1.3.3.17/conf/application.conf

 启动Kafka managerssh

bin/kafka-manager -Dconfig.file=/home/lintong/software/kafka-manager-1.3.3.17/conf/application.conf -Dhttp.port=7778

访问fetch

http://localhost:9000

而后在cluster中add cluster,好比.net

 

 启动Kafka的JMX,只须要修改kafka的启动命令就行,注意给kafka添加jmx须要在kafka manager以前scala

 启动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 建议采用此方法

 

 关于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  失败的生产请求

相关文章
相关标签/搜索