kafka
-
编辑 删除
验证kafka集群高可用
情形1：建一个topic:mytopic共3个分区，3个ReplicationFactor bin/kafka-topics.sh --create --zookeeper 192.168.135.130:2181,192.168.135.129:2181,192.168.135.131:2181 --replication-factor 3 --partitions 3 --topic mytopic Topic:mytopicPartitionCount:3ReplicationFactor:3Confi...
-
编辑 删除
使用kafka-reassign-partitions.sh重新对topic分区，ReplicationFactor由1变成3
1、准备topics-to-move.json用于--topics-to-move-json-file 2、准备output.json用于--reassignment-json-file 3、 bin/kafka-reassign-partitions.sh --zookeeper 127.0.0.1:2181 --topics-to-move-json-file topics-to-move.json --broker-list "0,1,2" --generate > output.js...
