kafka 创建topic_雅虎开源！可视化的Kafka监控管理工具
Kafka作为一个分布式的消息系统，由于可靠性高、吞吐量大、持久性强以及多样化的消费处理模型等特点，目前已经被很多公司应用在实际的业务中，在科技领域收获的一致好评！
不想进(tou)步(lan)的程序员不是好开发，本着这样一颗推动科技进(hua)步(fan)发(wei)展(jian)的初心，雅虎一行工程师研发出了一款kafka的管理利器——Kafka Manager！
kafka manager 是雅虎开源一个可视化的 kafka 管理工具，“懒人”必备！使用了它，你可以很容易就发现在集群中分布不均匀的topic，以及整个集群分布不均匀的情况；与此同时它还支持管理多个集群、选择副本、副本重新分配以及创建Topic。
目前支持的主要内容：
- 管理多个kafka集群
Cluster Management
- 便捷的检查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 List
- 为已存在的topic增加分区
- 为已存在的topic更新配置
- 在多个topic上批量重分区
- 在多个topic上批量重分区(可选partition broker位置)
Kafka Manager安装配置
下载
使用Git或者直接从Releases中下载，地址：https://github.com/yahoo/kafka-manager
部署
输入以下命令创建一个zip文件
./sbt clean dist如果java不在你的路径中，或者你需要构建特定的Java版本，可以参考使用以下参数配置(示例为oracle java8)：
$ PATH=/usr/local/oracle-java-8/bin:$PATH JAVA_HOME=/usr/local/oracle-java-8 /path/to/sbt -java-home /usr/local/oracle-java-8 clean dist确保首先在oracle java8版本中查找到路径中的“java”和“javac”二进制文件。
启动服务
运行Kafka Manager：
$ bin/kafka-manager
默认情况下，它会选择端口9000.例如：
$ bin/kafka-manager -Dconfig.file=/path/to/application.conf -Dhttp.port=8080PS：如果java不在你的路径中，或者你需要运行不同版本的java，需要添加-java-home选项，如下所示：
$ bin/kafka-manager -java-home /usr/local/oracle-java-8更多个性化的配置使用还请参考：https://github.com/yahoo/kafka-manager