1、节点服役
1、克隆准备其中一台节点
2、如果新节点的kafka有被log和datas文件夹要删除
3、修改/etc/hosts 配置新节点映射
1.1 执行负载均衡操作
vim topics-to-move.json
{"topic": "主题名称"}
{"topics":[{"topic":"first"}],"version":1}
生成负载均衡计划
注意
kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --topics-to-move-json-file topics-to-move.json --broker-list
"0,1,2,3"
--generate
kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --topics-to-move-json-file topics-to-move.json --broker-list "0,1,2,3" --generate
可以复制这个作为存储计划,也可以自定义
1.2 创建副本存储计划
vim increase-replication-factor.json
执行存储计划
kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --reassignment-json-file increase-replication-factor.json --execute
1.3 验证副本存储计划。
kafka-reassign-partitions.sh --bootstrap-server hadoop102:9092 --reassignment-json-file increase-replication-factor.json --verify
查看主题详情
kafka-topics.sh --bootstrap-server hadoop100:9092 --describe --topic first
2、节点退役
1.1 执行负载均衡操作
vim topics-to-move.json
{"topic": "主题名称"}
{"topics":[{"topic":"first"}],"version":1}
生成负载均衡计划
注意kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --topics-to-move-json-file topics-to-move.json --broker-list
"0,1,2"
--generate
kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --topics-to-move-json-file topics-to-move.json --broker-list "0,1,2" --generate
2.2 创建副本存储计划
vim increase-replication-factor.json
执行存储计划
kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --reassignment-json-file increase-replication-factor.json --execute
执行存储计划
kafka-reassign-partitions.sh --bootstrap-server hadoop100:9092 --reassignment-json-file increase-replication-factor.json --execute
2.3 验证副本存储计划。
kafka-reassign-partitions.sh --bootstrap-server hadoop102:9092 --reassignment-json-file increase-replication-factor.json --verify
查看主题详情
kafka-topics.sh --bootstrap-server hadoop100:9092 --describe --topic first
关闭想要退出的节点
$KAFKA_HOME/bin/kafka-server-start.sh -daemon $KAFKA_HOME/config/server.propertie
版权归原作者 Long long ago. 所有, 如有侵权,请联系我们删除。