2016-05-31 28 views
2

我有一个无效的代理,它并不存在。我错误地启动了一个带有无效ID的服务器,一会儿。Kafka:将分区从无效代理移动到

不过的话题之一之前分配给该经纪人:

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.我是对的吗?

但是如果我不想要它呢?我很好从这个经纪人丢失所有数据。我可以强迫卡夫卡选择新的领导者并重新平衡话题吗?手动,从命令行

回答

0

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

+0

是的,我也试过了,没有任何改变:(因此我从地面重新创建了整个群集,这是测试环境,所以不是一个大问题,但仍然是一个问题如果我要做什么在产品中获得相同的情况 –

相关问题