Kafka作为一个分布式的消息系统,由于可靠性高、吞吐量大、持久性强以及多样化的消费处理模型等特点,目前已经被很多公司应用在实际的业务中,在科技领域收获的一致好评!
不想进(tou)步(lan)的程序员不是好开发,本着这样一颗推动科技进(hua)步(fan)发(wei)展(jian)的初心,雅虎一行工程师研发出了一款kafka的管理利器——Kafka Manager!
kafka manager 是雅虎开源一个可视化的 kafka 管理工具,“懒人”必备!使用了它,你可以很容易就发现在集群中分布不均匀的topic,以及整个集群分布不均匀的情况;与此同时它还支持管理多个集群、选择副本、副本重新分配以及创建Topic。
目前支持的主要内容:
- 管理多个kafka集群
- 便捷的检查kafka集群状态(topics,brokers,备份分布情况,分区分布情况)
- 选择你要运行的副本
- 基于当前分区状况进行
- 可以选择topic配置并创建topic(0.8.1.1和0.8.2的配置不同)
- 删除topic(只支持0.8.2以上的版本并且要在broker配置中设置delete.topic.enable=true)
- Topic list会指明哪些topic被删除(在0.8.2以上版本适用)
- 为已存在的topic增加分区
- 为已存在的topic更新配置
- 在多个topic上批量重分区
- 在多个topic上批量重分区(可选partition broker位置)
下载
使用Git或者直接从Releases中下载,地址:https://github.com/yahoo/kafka-manager
部署
输入以下命令创建一个zip文件
如果java不在你的路径中,或者你需要构建特定的Java版本,可以参考使用以下参数配置(示例为oracle java8):
确保首先在oracle java8版本中查找到路径中的“java”和“javac”二进制文件。
启动服务
运行Kafka Manager:
默认情况下,它会选择端口9000.例如:
PS:如果java不在你的路径中,或者你需要运行不同版本的java,需要添加-java-home选项,如下所示: