我正在使用卡夫卡 0.8.1.1。我有一个 3 节点 kafka 集群,其中一些主题有大约 5 个分区。我计划将集群中的节点数量增加到 5 个,并将一些分区从现有主题移动到新的代理。
Previous partition state:
broker1 : topic1 { partition 0 }
broker2 : topic1 { partition 1,2}
broker3 : topic1 { partition 3,4}
New intended state:
broker1 : topic1 { partition 0}
broker2 : topic1 { partition 1}
broker3 : topic1 { partition 3}
broker4 : topic1 { partition 4}
broker5 : topic1 { partition 2}
command which I used:
bin/kafka-reassign-partitions.sh --reassignment-json-file partitions-to-move.json --zookeeper zkserver1:2181,zkserver2:2181,zkserver3:2181 --execute
partitions-to-move.json
{
"partitions":[{"topic": "topic1","partition": 4,"replicas": [4] }],
"version":1
}
我看到的错误消息:
[2015-12-22 11:19:46,447] WARN [KafkaApi-2] Produce request with correlation id 2462842 from client kafka-node-client on partition [topic1,4] failed due to Partition [topic1,4] doesn't exist on 3 (kafka.server.KafkaApis)
我进行了搜索,但找不到任何相关答案。感谢任何指导/帮助来解决这个问题。