一、kafka-manager 简介
kafka-manager 项目地址:https://github.com/yahoo/kafka-manager
二、安装
1. 环境要求
本次实验所用的环境是kafka-0.9.1.0 , jdk-1.8.0_60 , zookeeper-3.4.7,下载解压安装运行
# start zookeepercd /usr/local/zookeeper-3.4.7./bin/zkServer.sh start## start kafkacd /usr/local/kafka_2.11-0.9.0.0./bin/kafka-server-start.sh ./config/server.properties
2. 下载安装 kafka-manager
下载编译
git clone https://github.com/yahoo/kafka-managercd kafka-manager
cd kafka-manager# 因为要编译。所以下面这步操作要等很久sbt clean distcd target/
# 在target目录下我们可以看到 kafka-managerkafka-manager-1.3.0.8.zip
tips:
使用sbt编译打包的时候时间可能会比较长,如果你hang在
Loading project definition from kafka-manager/project
可以修改project/plugins.sbt中的LogLevel参数
将logLevel := Level.Warn修改为logLevel := Level.Debug
解压
unzip kafka-manager-1.3.0.8.zip -d /usr/local
cd /usr/local/kafka-manager-1.3.0.8
修改配置 conf/application.properties
# 如果zk是集群,这里填写多个zk地址kafka-manager.zkhosts="localhost:2181"
启动
bin/kafka-manager
kafka-manager 默认的端口是9000,可通过 -Dhttp.port,指定端口; -Dconfig.file=conf/application.conf指定配置文件:
nohup bin/kafka-manager -Dconfig.file=conf/application.conf -Dhttp.port=8080 &
我们用浏览器访问试试,界面非常简洁
Paste_Image.png
三、测试 kafka-mamager
1. 新建 Cluster
填写cluster名--zk地址
zk
建好之后看到如下界面
Paste_Image.png
2. 新建 topic
填写分区和副本个数
topic
3. 查看我们的 topic
topic-list
4. 启动 consumer
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic test-a
5. 启动 producer,并在启动后的console输入一些信息
Broker
bin/kafka-console-producer.sh --broker-list 10.26.236.43:9092 --topic test-a
输入 message
message
可以看到 consumer 已经收到消息
consumer
CIO之家 www.ciozj.com 公众号:imciow