java - 卡夫卡 : move partition from invalid broker

Question

我有一个无效的经纪人，它实际上并不存在。我暂时错误地启动了一个无效 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 会等到原始 Broker 100 启动后才将数据从它复制到 Broker 1。我说得对吗？

但是如果我不想要怎么办？我可以丢失该经纪人的所有数据。我可以强制 Kafka 选择新的领导者并重新平衡主题吗？手动，从命令行

Answer 1

只是猜测，但是您是否尝试过使用 bin/kafka-preferred-replica-election.sh --zookeeper zk_host:port/chroot 方法。