kafka-manager怎么用

这篇文章将为大家详细讲解有关kafka-manager怎么用，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

雅虎官方github项目：https://github.com/yahoo/kafka-manager

这里提供编译好了的包，下载后可以直接使用，可以不用去sbt编译。

链接：http://pan.baidu.com/s/1bQ3lkM 密码：c251

1、将下载后的包上传到linux目录下解压

unzip  kafka-manager-1.3.0.7.zip
mv kafka-manager-1.3.0.7 kafka-manager

2、修改配置文件

修改application.conf中zk配置

vim kafka-manager/conf/application.conf
修改配置：
kafka-manager.zkhosts=
添加配置：
http.port=   （默认9000）

3、由于使用kafkamanage是在jdk8基础上的，所以先安装jdk8,只需下载解压即可。

4、想要看到读取,写入速度需要开启JMX，修改kafka-server-start.sh 添加一行即可：添加JMX端口8999

if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
    export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
    export JMX_PORT="8999"
fi

注意：每个kafka broker都需要修改，修改后进行重启kafka。

5、启动kafka manager

cd kafka-manager/bin
./kafka-manager -java-home /path/to/java1.8

后台运行：

nohup ./kafka-manager -java-home /path/to/jdk8 -Dconfig.file=../conf/application.conf >/dev/null 2>&1 &

6、在localhost:9000查看web页面。

(1)创建cluster: 点击顶部Cluster、Add Cluster

(2)配置cluster:

名字；集群zkhost格式：host1:2181,host2:2181,host3:2181

kafka版本，勾选上JMX和下面的勾选框，可显示更多指标

7、创建完毕后，可查看

topics相关：

关于“kafka-manager怎么用”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。