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.我是对的吗?
但是如果我不想要它呢?我很好从这个经纪人丢失所有数据。我可以强迫卡夫卡选择新的领导者并重新平衡话题吗?手动,从命令行
是的,我也试过了,没有任何改变:(因此我从地面重新创建了整个群集,这是测试环境,所以不是一个大问题,但仍然是一个问题如果我要做什么在产品中获得相同的情况 –