我們可以使用 bin/kafka-topics.sh 命令對 Kafka 增加 Kafka 的分區數據,但是 Kafka 不支持減少分區數。 Kafka 分區數據不支持減少是由很多原因的,比如減少的分區其數據放到哪里去?是刪除,還是保留?刪除的話,那么這些沒消費的消息不就丟了。如果保留這些消息如何放到其他分區里面?追加到其他分區后面的話那么就破壞了 Kafka 單個分區的有序性。如果要保證刪除分區數據插入到其他分區保證有序性,那么實現起來邏輯就會非常復雜。
我們可以使用 bin/kafka-topics.sh 命令對 Kafka 增加 Kafka 的分區數據,但是 Kafka 不支持減少分區數。 Kafka 分區數據不支持減少是由很多原因的,比如減少的分區其數據放到哪里去?是刪除,還是保留?刪除的話,那么這些沒消費的消息不就丟了。如果保留這些消息如何放到其他分區里面?追加到其他分區后面的話那么就破壞了 Kafka 單個分區的有序性。如果要保證刪除分區數據插入到其他分區保證有序性,那么實現起來邏輯就會非常復雜。
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。