kafka-manager 部署安装

一、功能

1、管理多个kafka集群  
2、便捷的检查kafka集群状态(topics,brokers,备份分布情况,分区分布情况)  
3、选择你要运行的副本  
4、基于当前分区状况进行  
5、可以选择topic配置并创建topic(0.8.1.1和0.8.2的配置不同)  
6、删除topic(只支持0.8.2以上的版本并且要在broker配置中设置delete.topic.enable=true)  
7、Topic list会指明哪些topic被删除（在0.8.2以上版本适用）  
8、为已存在的topic增加分区  
9、为已存在的topic更新配置  
10、在多个topic上批量重分区  
10、在多个topic上批量重分区(可选partition broker位置)  

二、安装部署

• yum安装sbt(因为kafka-manager需要sbt编译)

curl https://bintray.com/sbt/rpm/rpm -o bintray-sbt-rpm.repo  
mv bintray-sbt-rpm.repo /etc/yum.repos.d/  
yum install sbt  

• 下载kafka-manager并编译

cd /opt  
git clone https://github.com/yahoo/kafka-manager  
cd kafka-manager  
./sbt clean dist
cd target/universal/  
unzip kafka-manager-1.3.3.21.zip  
mv kafka-manager-1.3.3.21 /opt/kafka-manager  

• 修改配置文件/opt/kafka-manager/conf/application.properties

 http.port=8080   #默认9000，由于我用的CDH，cdh占用了9000端口，所以更改了下
 kafka-manager.zkhosts="md-sh-centos7-1-cdh-003:2181,md-sh-centos7-1-cdh-004:2181,md-sh-centos7-1-cdh-005:2181"

• 启动

nohup /opt/kafka-manager/bin/kafka-manager  -Dconfig.file=/opt/kafka-manager/conf/application.conf  &  
# 加入开机启动项
echo "nohup /opt/kafka-manager/bin/kafka-manager  -Dconfig.file=/opt/kafka-manager/conf/application.conf  &" >> /etc/rc.local  

• 登陆WEBUI查看

http://md-sh-centos7-cdh-001:8080/