kafka manager

正文

kafka manager 是雅虎开源一个可视化的 kafka 管理工具，懒人必备。当然如果你更倾向使用命令，会显得逼格更高，随你。

源码下载

kafka-manager

编译

解压后，根目录下执行以下命令编译 ( 确保已安装 Java 环境 )

sbt clean dist

受网络影响，编译可能会花很长的时间，如果不能等可以尝试修改 sbt 的maven 仓库。编译完成后，会在 target\universal 目录下会生成一个编译好的压缩包

注意： sbt 如果没有安装， 点击下载 ，安装成功后重新执行编译命令

启动 kafka manager

可以将压缩包复制到你想存放的地方，解压后根据你的 zookeeper 集群地址，修改 conf\application.conf 的 kafka-manager.zkhosts 节点，比如我的测试环境 zookeeper 集群：

kafka-manager.zkhosts="localhost:2181,localhost:2182,localhost:2183"

修改完成回到根目录，执行以下命令，启动成功后的默认访问端口是 9000，也可以通过启动参数重新配置。

请确保 kafka 集群和 zookeeper 集群都已启动完成

bin\kafka-manager

默认一片空白，需要我们手动添加集群，添加时只需要设置一下 Cluster Name 和 Cluster Zookeeper Hosts ，其他配置后续根据需要再设置。根据实际环境需要，可以添加多个集群。

添加成功后，我们可以通过可视化界面查看每个集群的信息，如：Borker 、Topic 、Consumer、Partition 的分布情况、Topic 副本等等，这个自己玩一下就基本知道有哪些东西了。

启用 JMX

kafka 可以配置使用 JMX 进行运行状态的监控。

1. 修改 kafka-server-start 文件

   Windows
   kafka-server-start.bat 添加 set JMX_PORT=9992

   IF ["%KAFKA_HEAP_OPTS%"] EQU [""] (
     ...
     set JMX_PORT=9999
   )
   

   Linux
   kafka-server-start.sh 添加 export JMX_PORT=”9999”

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

2. 重启 kafka

请到「今天看啥」查看全文