我有一个无效的经纪人,其实并不存在。我错误地启动了一个id无效的服务器。
但其中一个主题是之前分配给这个经纪人的:
Topic:raw-logs PartitionCount:3 ReplicationFactor:1 Configs:
Topic: raw-logs Partition: 0 Leader: -1 Replicas: 100 Isr:
Topic: raw-logs Partition: 1 Leader: none Replicas: 2 Isr:
Topic: raw-logs Partition: 2 Leader: none Replicas: 3 Isr:
我已经尝试重新分配分区
{"topic":"raw-logs","partition":0,"replicas":[1]}
但这并没有改变什么。我猜kafka会等到原始broker100将数据复制到broker1。我说得对吗?
但如果我不想要呢?我可以把这个经纪人的资料都丢了。我能强迫Kafka选择新的领导人和重新平衡主题吗?手动,从命令行
1条答案
按热度按时间sd2nnvve1#
只是猜测,但是您是否尝试过使用bin/kafka-preferred-replica-election.sh--zookeeper zk_host:port/chroot 方法。