网站建设的需求文档,虚拟主机技术,网络推广宣传方式,商业网站平台目录 一、服务器信息二、先启动4台zookeeper#xff0c;再启动4台kafka三、通过PrettyZoo工具验证启动的kafka是否ok四、查看4台kafka集群节点上是否存在创建的名称为news的主题五、退役旧节点5.1、执行负载均衡操作5.2、 执行停止命令5.3、再次查看kafka中的创建过的名称为ne… 目录 一、服务器信息二、先启动4台zookeeper再启动4台kafka三、通过PrettyZoo工具验证启动的kafka是否ok四、查看4台kafka集群节点上是否存在创建的名称为news的主题五、退役旧节点5.1、执行负载均衡操作5.2、 执行停止命令5.3、再次查看kafka中的创建过的名称为news的topic 一、服务器信息
三台服务器 原始服务器名称原始服务器ipcentos7虚拟机1192.168.136.27centos7虚拟机2192.168.136.28centos7虚拟机3192.168.136.29centos7虚拟机4192.168.136.30
二、先启动4台zookeeper再启动4台kafka 分别启动4台zookeeper [rootlocalhost /]# cd /opt/module/zookeeper-3.5.7/bin/
[rootlocalhost bin]# pwd
/opt/module/zookeeper-3.5.7/bin
[rootlocalhost bin]# sh zkServer.sh start再分别启动4台kafka [rootlocalhost bin]# cd /opt/module/kafka-3.0.0/
[rootlocalhost kafka-3.0.0]# pwd
/opt/module/kafka-3.0.0
[rootlocalhost kafka-3.0.0]# bin/kafka-server-start.sh -daemon config/server.properties
[rootlocalhost kafka-3.0.0]# jps三、通过PrettyZoo工具验证启动的kafka是否ok brokers中的ids0、1、2、3都存在说明4台kafka启动正常如下图
四、查看4台kafka集群节点上是否存在创建的名称为news的主题 查看kafka中的创建过的名称为news的topic由下图可知在4台服务器创建的名称为news的主题都存在。 [rootlocalhost home]# cd /opt/module/kafka-3.0.0/
[rootlocalhost kafka-3.0.0]# bin/kafka-topics.sh --bootstrap-server 192.168.136.27:9092 --topic news --describe五、退役旧节点
5.1、执行负载均衡操作 创建一个要均衡的主题。 [rootlocalhost kafka-3.0.0]# vi topics-to-move.json
{topics: [{topic: news}],version: 1
}创建执行计划。 bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.136.27:9092 --topics-to-move-json-file topics-to-move.json --broker-list 0,1,2 --generate创建副本存储计划所有副本存储在 broker0、broker1、broker2 中。 [rootlocalhost kafka-3.0.0]# vi increase-replication-factor.json
{version:1,partitions:[{topic:first,partition:0,replicas:[2,0,1],log_dirs:[any,any,any]},{topic:first,partition:1,replicas:[0,1,2],log_dirs:[any,any,any]},{topic:first,partition:2,replicas:[1,2,0],log_dirs:[any,any,any]}]}执行副本存储计划。 [rootlocalhost kafka-3.0.0]# bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.136.27:9092 --reassignment-json-file increase-replication-factor.json --execute验证副本存储计划。 [rootlocalhost kafka-3.0.0]# bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.136.27:9092 --reassignment-json-file increase-replication-factor.json --verify5.2、 执行停止命令 在192.168.136.30服务器上执行停止kafka命令。 [rootlocalhost kafka-3.0.0]# bin/kafka-server-stop.sh5.3、再次查看kafka中的创建过的名称为news的topic 再次查看kafka中的创建过的名称为news的topic由下图可知在4台服务器中只有3台服务器创建了名称为news的主题。 [rootlocalhost home]# cd /opt/module/kafka-3.0.0/
[rootlocalhost kafka-3.0.0]# bin/kafka-topics.sh --bootstrap-server 192.168.136.27:9092 --topic news --describe
