网站产品图怎么做,专业网页制作软件都能帮助用户组织和管理,微信里的小程序怎么添加,jsp做的网站有哪些目录 一、服务器信息二、启动zookeeper和kafka集群2.1、先启动zookeeper集群2.2、再启动kafka集群 三、增加副本因子3.1、增加副本因子的概述3.2、增加副本因子的示例3.2.1、创建topic(主题)3.2.2、手动增加副本存储 一、服务器信息
四台服务器 原始服务器名称原始服务器ip节点… 目录 一、服务器信息二、启动zookeeper和kafka集群2.1、先启动zookeeper集群2.2、再启动kafka集群 三、增加副本因子3.1、增加副本因子的概述3.2、增加副本因子的示例3.2.1、创建topic(主题)3.2.2、手动增加副本存储 一、服务器信息
四台服务器 原始服务器名称原始服务器ip节点centos7虚拟机1192.168.136.27broker0centos7虚拟机2192.168.136.28broker1centos7虚拟机3192.168.136.29broker2centos7虚拟机4192.168.136.30broker3
二、启动zookeeper和kafka集群
2.1、先启动zookeeper集群 启动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 start2.2、再启动kafka集群 启动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三、增加副本因子
3.1、增加副本因子的概述
在生产环境当中由于某个主题的重要等级需要提升我们考虑增加副本。副本数的 增加需要先制定计划然后根据计划执行。
3.2、增加副本因子的示例
3.2.1、创建topic(主题) 创建名称为twotopic的topic(主题) bin/kafka-topics.sh --bootstrap-server 192.168.136.27:9092 --create --partitions 4 --replication-factor 1 --topic twotopic查看分区副本存储情况由下图可知目前分布在broker0、broker1、broker2和broker3的4台服务器的某一个服务器上。 bin/kafka-topics.sh --bootstrap-server 192.168.136.27:9092 --describe --topic twotopic3.2.2、手动增加副本存储 创建副本存储计划所有副本都指定存储在 broker0、broker1、broker2 和broker3中。 vim increase-replication-factor.json
//增加以下内容
{version:1,partitions:[{topic:twotopic,partition:0,replicas:[0,1,2,3]},{topic:twotopic,partition:1,replicas:[0,1,2,3]},{topic:twotopic,partition:2,replicas:[0,1,2,3]},{topic:twotopic,partition:3,replicas:[0,1,2,3]}]
}执行副本存储计划。 bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.136.27:9092 --reassignment-json-file increase-replication-factor.json --execute验证副本存储计划。 bin/kafka-reassign-partitions.sh --bootstrap-server 192.168.136.27:9092 --reassignment-json-file increase-replication-factor.json --verify查看分区副本存储情况。 由下图可知 所有副本都指定存储在 broker0、broker1、broker2 和broker3中。
