前期博客

基于Web的Kafka管理器工具之Kafka-manager的编译部署详细安装 (支持kafka0.8、0.9和0.10以后版本)（图文详解）

 

基于Web的Kafka管理器工具之Kafka-manager启动时出现Exception in thread "main" java.lang.UnsupportedClassVersionError错误解决办法（图文详解）

 

 

 

 

　　然后

第一次进入web UI要进行kafka cluster的配置,都是一些比较简单的操作。

 

配置集群

　　点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面：

 

 

 

 

 

 

 

 

 

 

 

　　它会自动识别出，当前，你所用的kafka版本

 

 

 

 

 　　当然，这里，大家后期还可以微调kafka的版本。当然是与自己集群的版本一致！

 

 

 

 

　　当然，大家也可以给输入集群的名字（如Kafka-Cluster-1）和 Zookeeper 服务器地址（如localhost:2181）。

 

 

　　我这里给

　　Cluster Nmae赋值为kafka

　　Cluster Zookeeper Hosts为master:2181,slave1:2181,slave2:2181

 

 

 　　kafka version，就选择我当前用的版本（它会默认识别到）。  

 

 

注意：　如果没有在 Kafka 中配置过 JMX_PORT，千万不要选择第一个复选框。

　　　　   Enable JMX Polling

　　　　     如果选择了该复选框，Kafka-manager 可能会无法启动。

 

　　我这里，是没有配置JMX_PORT

 

 

 

 

 

 

 　　然后，其他broker的配置可以根据自己需要进行配置。如下

 

 

 

 

 

 

 

 

 

 　　

 　　默认情况下，点击【保存】时，会提示几个默认值为1的配置错误，需要配置为>=2的值。保存成功后，提示如下。

 

 

 

 

 

 

 　　然后，如下

 

 

 

 

 　　点击【Go to cluster view.】打开当前的集群界面。

 

 

 

 　　

　　在集群界面显示了主题和Broker的个数，点击数字可以查看具体的信息。

　　同时在顶部多了好几个菜单，可以查看集群、Broker、主题等信息。

 

 

 

 

 

 

新建主题

　　点击【Topic】>【Create】可以方便的创建并配置主题。如下显示。

 

 

　　这里，推荐去先看下我下面的博客，

kafka的topic命名技巧

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

更多的其他详细操作

　　关于kafka-manager的其他功能和操作可以参考官网：https://github.com/yahoo/kafka-manager

 

 

 

 

 

 

 

 

参考

Apache Kafka 入门 - Kafka-manager的基本配置和运行