Kafka 分区数可以增加或减少吗?为什么?

我们可以使用 bin/kafka-topics.sh 命令对 Kafka 增加 Kafka 的分区数据 ,但是 Kafka 不支持减少 分区数。

Kafka 分区数据 不支持减少 是由很多原因的,比如减少的分区 其数据放到哪里去? 是删除,还是保留? 删除的话, 那么这些没消费的消息 不就丢了。 如果保留这些消息 如何放到 其他分区里面? 追加到 其他分区 后面的话 那么就破坏了 Kafka 单个分区的有序性。 如果 要保证删除分区数据插入到其他分区 保证有序性,那么实现起来逻辑就会非常复杂。

标签: 、面试
  • 回复
隐藏