kafka-web

官网的包得需要编译，太过于麻烦，本次提供编译好的包，直接修改配置文件即可[vip]

root@localhost ~]# git clone https://github.com/cncentoscn/kafka-manager.git

编辑配置文件

[root@localhost conf]# pwd
/opt/kafka-manager-1.3.3.7/conf
[root@localhost conf]# vim application.conf
#kafka-manager.zkhosts="localhost:2181" ###注释掉这行
kafka-manager.zkhosts="192.168.1.58:2181,192.168.1.59:2181,192.168.1.60:2181"

安装java

[root@localhost conf]# yum -y install java-1.8.0-openjdk*

[root@localhost conf]# nohup /opt/kafka-manager-1.3.3.7/bin/kafka-manager >/dev/null 2>&1 &
[1] 19724
[root@localhost conf]# ss -tnlp
State Recv-Q Send-Q Local Address:Port Peer Address:Port 
LISTEN 0 128 *:22 *:* users:(("sshd",pid=933,fd=3))
LISTEN 0 100 127.0.0.1:25 *:* users:(("master",pid=1674,fd=13))
LISTEN 0 128 :::22 :::* users:(("sshd",pid=933,fd=4))
LISTEN 0 100 ::1:25 :::* users:(("master",pid=1674,fd=14))
LISTEN 0 50 :::9000 :::* users:(("java",pid=19724,fd=129))

kafka-manager 默认的端口是9000，可通过 -Dhttp.port，指定端口; -Dconfig.file=conf/application.conf指定配置文件:

[root@kafka-manager conf]# nohup bin/kafka-manager -Dconfig.file=/data/kafka-manager-1.3.3.7/conf/application.conf -Dhttp.port=8080 &

http://192.168.1.215:9000/

点击【Cluster】>【Add Cluster】打开如下添加集群的配置界面：
输入集群的名字（如Kafka-GR）和 Zookeeper 服务器地址（如localhost:2181），选择最接近的Kafka版本（如0.10.1.1）
-------------------------------------------------------------------
注意：如果没有在 Kafka 中配置过 JMX_PORT，千万不要选择第一个复选框。
Enable JMX Polling
如果选择了该复选框，Kafka-manager 可能会无法启动。

点击保存

成功后的界面

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

点击创建

查看刚创建的Topic

由于集群只有三个节点，故replication factor最多只能设置为3

查看

针对上面Topic->Create新建主题的配置，下面根据一张图讲解

在上图一个Kafka集群中，有两个服务器，每个服务器上都有2个分区。P0,P3可能属于同一个主题，也可能是两个不同的主题。
如果设置的Partitons和Replication Factor都是2，这种情况下该主题的分步就和上图中Kafka集群显示的相同，此时P0,P3是同一个主题的两个分区。P1,P2也是同一个主题的两个分区，Server1和Server2其中一个会作为Leader进行读写操作，另一个通过复制进行同步。
如果设置的Partitons和Replication Factor都是1，这时只会根据算法在某个Server上创建一个分区，可以是P0~4中的某一个（分区都是新建的，不是先存在4个然后从中取1个）。

</a[/vip]>