kafka發送消息分區策略詳解

背景：java      一個簡單的用scala往kafka裏寫數據demo,每次運行只往一個分區寫入數據，下次運行又選另外一個分區一直寫入。算法 發送例子：dom def main(args: Array[String]): Unit = { val topic = "test02" val brokers = "demo169.test.com:6667,demo167.tes

>>阅读原文<<