Centos7编译安装Kafka-manager-2.0.0.2
程序开发者社区 人气:2一、Kafka manager简介
项目地址为:https://github.com/yahoo/kafka-manager
为了简化开发者和服务工程师维护Kafka集群的工作,yahoo构建了一个叫做Kafka管理器的基于Web工具,叫做 Kafka Manager。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀,或者是分区在整个集群分布不均匀的的情况。它支持管理多个集群、选择副本、副本重新分配以及创建Topic。同时,这个管理工具也是一个非常好的可以快速浏览这个集群的工具,有如下功能:
- 管理kafka集群
- 方便集群状态监控 (包括topics, consumers, offsets, brokers, replica distribution, partition distribution)
- 方便选择分区副本
- 配置分区任务,包括选择使用哪些brokers
- 可以对分区任务重分配
- 提供不同的选项来创建及删除topic
- Topic list会指明哪些topic被删除
- 批量产生分区任务并且和多个topic和brokers关联
- 批量运行多个主题对应的多个分区
- 向已经存在的主题中添加分区
- 对已经存在的topic修改配置
- 可以在broker level和topic level的度量中启用JMX polling功能
- 可以过滤在ZK上没有ids/ owners/offsets/ directories的consumer
二、下载kafka-manager源码包
源码包下载地址:https://github.com/yahoo/kafka-manager/archive/2.0.0.2.tar.gz
github上没有提供安装包,需要我们自行编译之后在进行安装,需要现在sbt编译工具。
再此我已经编译好安装包了kafka-manager-2.0.0.2.zip,可以直接下载使用:http://pan.baidu.com/s/1XukGHykub5OdJvyeudqVPg 提取码:w4q4
看到我这篇文章,就不要去编译,没意思,直接从百度网盘链接下载编译好的安装包就行了,编译步骤参考一下就行了。
三、安装sbt-1.3.5
因为Kafka-manager使用的Play框架,为了编译的速度更快,先配置sbt的maven仓库,由于默认仓库速度较慢,因此使用aliyun提供的maven仓库。
修改仓库地址:(sbt 默认下载库文件很慢, 还时不时被打断,不行的话就重试),我们可以在用户目录下创建 touch ~/.sbt/repositories, 填上阿里云的镜像 # vi ~/.sbt/repositories
内容:
以上配置文件解释顺序是:本地→阿里云镜像→jcenter→typesafe-ivy-releases→Maven主镜像。如果需要添加公司的maven镜像,可以按照 key: value 的形式添加,key 的命名没有要求(暂时没注意到,但是最好也不要用什么特殊符号吧)
验证:检查sbt是否安装成功,查看命令输出,发现已经成功可以从maven.aliyun.com/nexus
下载到依赖即表示成功
需要很长时间~耐心等待,我这里已经执行过了,再次执行显示如下:
四、解压编译kafka-manager源码包
在【二、下载kafka-manager源码包】步骤中我们已经已下载了源码包,
解压kafka-manager源码包:
解压后显示目录如下
然后执行:
编译时间会很长,需要耐心等待,可以到~/.sbt/boot/update.log 查看sbt更新日志。sbt更新好,就开始下载各种jar包,最后看到:[info] Your package is ready in /home/soft/kafka-manager-2.0.0.2/target/universal/kafka-manager-2.0.0.2.zip 证明编译好了。
我这个已经编译过了,由于记录笔记,我再次进行了编译就很快了,日志如下:
五、安装kafka-manager
由于使用kafka-manager是在JDK8基础上的,所以先安装JDK8,JDK安装不再叙述。
由于【四、解压编译kafka-manager源码包】步骤已经编译完成,我们可以把 /home/soft/kafka-manager-2.0.0.2/target/universal/kafka-manager-2.0.0.2.zip 的安装包移动到你要安装的地方解压。
在此我解压到/usr/local/目录下
解压后查看目录如下:
接下来就是配置kafka-manager了
想要看到读取,写入速度需要开启JMX,修改kafka-server-start.sh 添加一行即可:添加JMX端口8999
注意:每个kafka broker都需要修改,修改后进行重启kafka。
最后,启动kafka-manager
六、测试kafka-manager
访问:http://192.168.184.133:9090/
1、新建Cluster
点击【Cluster】>【Add Cluster】打开如下添加集群配置界面:输入集群的名字(如KafkaCluster
)和 Zookeeper 服务器地址(如192.168.184.133:2181/kafka
),选择最接近的Kafka版本
其他broker的配置可以根据自己需要进行配置,默认情况下,点击【保存】时,会提示几个默认值为1
的配置错误,需要配置为>=2
的值。提示如下。
添加完集群之后查看
topics相关:
更多页面功能自己点点就行了。。。
更多信息查看github上kafka-manager的README.md:https://github.com/yahoo/kafka-manager/blob/master/README.md
加载全部内容