• 欢迎访问运维搬运工网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站。
  • 本站一年会员:100元 ,两年会员:180元 ,永久会员:380元
  • 这世界就是,一些人总在昼夜不停地运转,而另外一些人,起床就发现世界已经变了。
  • 本博客推广的是知识付费,用赞助的方式实现博客维护,不以赚钱为目的的博客

kafka-web

简述

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

注意:本段内容须“登录”后方可查看!

下载

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个)。

查看消息

 


喜欢 (0)
[扫描二维码]
分享 (0)
大自然搬运工
关于作者:
不是路不平,而是你不行。到底行不行,看你停不停。只要你不停,早晚都能行。
发表我的评论
取消评论
表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址
(1)个小伙伴在吐槽