kafka-web

IT
IT
IT
335
文章
1
评论
2020年5月15日13:57:45 评论 1,252 1840字阅读6分8秒

简述

官网的包得需要编译,太过于麻烦,本次提供编译好的包,直接修改配置文件即可[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/

kafka-web

创建集群

kafka-web

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

kafka-web

 

点击保存

kafka-web

成功后的界面

kafka-web

kafka-web

查看TOPIC 信息

kafka-web

查看broker信息

kafka-web

管理 kafka-mamager

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

kafka-web

kafka-web

点击创建

kafka-web

 

查看刚创建的Topic

kafka-web

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

kafka-web

kafka-web

查看

kafka-web

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

kafka-web

在上图一个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个)。

查看消息

kafka-web

kafka-web

kafka-web

kafka-web</a[/vip]>

 

继续阅读
  • 我的QQ
  • QQ扫一扫
  • weinxin
  • 我的头条
  • 头条扫一扫
  • weinxin
IT
  • 本文由 发表于 2020年5月15日13:57:45
  • 除非特殊声明,本站文章均为原创,转载请务必保留本文链接
kafka集群 kafka

kafka集群

系统环境 1、操作系统:64位CentOS Linux release 7.2.1511 (Core) 2、jdk版本:1.8.0_121 3、zookeeper版本:zookeeper-3.4.9....
单机版kafka kafka

单机版kafka

下载 安装zookeeper # wget http://mirrors.hust.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10....