修改kafka的分区和副本设置

xiaoxiao2021-02-28  28

1.      查看topic的描述

#./kafka-topics.sh --describe --zookeeper snn:2181 --topictest-qt-001

2.   编写副本再赋值脚本

创建文本文件”partitions-to-move.json”,

# vim partitions-to-move.json.json

输入文本:

{ “version”:1, “partitions”:[ {“topic”:”test-qt-001”, “partition”:0, “replicas”:[1002, 1003]}          … ] }

3.      执行

./kafka-reassign-partitions.sh --zookeeper snn:2181 --reassignment-json-file partitions-to-move.json –execute

4.      查看

./kafka-topics.sh --describe --zookeeper snn:2181 --topictest-qt-001

 

转载请注明原文地址: https://www.6miu.com/read-2500149.html

最新回复(0)