开放原子开发者工作坊

kafka-manager 简介

# 项目信息
https://github.com/yahoo/kafka-manager

安装

环境要求：
Kafka 0.8.. or 0.9.. or 0.10..
Java 8+
zookeeper 2+

启动kafka集群

先修改kafka启动脚本

想要看到读取,写入速度需要开启JMX
#要在kafka启动脚本中添加JMX_PORT
#bin/kafka-server-start.sh
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then  
    export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"  
    export JMX_PORT="9999"  
fi
启动命令
./bin/kafka-server-start.sh config/server.properties &

　

下载,编译,打包

git clone https://github.com/yahoo/kafka-manager

编译
./sbt clean dist
比较麻烦

　　

启动kafka-manager

修改配置 conf/application.properties
# 如果zk是集群，这里填写多个zk地址
kafka-manager.zkhosts="localhost:2181"

启动
bin/kafka-manager
默认情况下端口为9000，你还可以通过下面的命令指定配置文件和端口
bin/kafka-manager -Dconfig.file=/path/to/application.conf -Dhttp.port=8080

如果没有配置Java的环境变量，还可以通过下面的方式指定Java8的目录：
bin/kafka-manager -java-home /usr/local/oracle-java-8

https://github.com/yahoo/kafka-manager

　

常用启动命令：
nohup ./bin/kafka-manager -Dconfig.file=./conf/application.conf -Dhttp.port=8080 > kafka-manager.log &

 

 

 启动后，访问配置如下：开启ＪＭＸ