kafka消息分區機制

首先咱們來看下官網的圖示，kafka分區的做用我的以爲就是提供一種負載均衡的能力，或者說對數據進行分區的主要緣由，就是爲了實現系統的高伸縮性（Scalability）。不一樣的分區可以被放置到不一樣節點的機器上，而數據的讀寫操做也都是針對分區這個粒度而進行的，這樣每一個節點的機器都能獨立地執行各自分區的讀寫請求處理。而且，咱們還能夠經過添加新的節點機器來增長總體系統的吞吐量。java 分區策略 下

>>阅读原文<<