简述
官网的包得需要编译,太过于麻烦,本次提供编译好的包,直接修改配置文件即可[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 信息
查看broker信息
管理 kafka-mamager
新建主题
点击【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个)。
查看消息
- 我的QQ
- QQ扫一扫
-
- 我的头条
- 头条扫一扫
-
评论