我们可以使用 bin/kafka-topics.sh 命令对 Kafka 增加 Kafka 的分区数据 ,但是 Kafka 不支持减少 分区数。
Kafka 分区数据 不支持减少 是由很多原因的,比如减少的分区 其数据放到哪里去? 是删除,还是保留? 删除的话, 那么这些没消费的消息 不就丢了。 如果保留这些消息 如何放到 其他分区里面? 追加到 其他分区 后面的话 那么就破坏了 Kafka 单个分区的有序性。 如果 要保证删除分区数据插入到其他分区 保证有序性,那么实现起来逻辑就会非常复杂。
浙公网安备 33010602006230号
浙ICP备14015892号