kafka的broker id 填写错误的问题
近日要搞kafka集群降配,因此要检查一下这个kafka集群的所有topic是否副本数有等于1的。
1 | ./kafka-topics.sh --zookeeper timoq-zk1:2181 --describe | grep 'ReplicationFactor:1' |
这样就能列出来,果然有几个topic还是1个副本的,那个就开始搞成2个副本。其实kafka可以给你生成的副本配置的json的。
1 | ./kafka-reassign-partitions.sh --zookeeper timo-zk1:2181 --topics-to-move-json-file topic-generate.json --broker-list "0,1,2,3,4,5,6" --generate |
但是这种生成出来的json文件无法跟现有的对照起来,我是希望现在分区谁是leader,后面还是leader,于是就手动写了个json文件。
1 | {"version":1, "partitions":[ |