kafka 發送數據，如何確定partition源碼解釋

每一個record 都有一個key 其作用在於 　　1 作爲一個record的元數據 　　2 用於分區，以便確定record進入到哪個,那麼具體代碼是如何實現的呢？我們查看下源碼 partition 　　　　如果所有的message是同一個key,將會被放入同一個partition kafka發送一個消息的流程 　　　　1 判斷有沒有攔截器，如果有攔截器就會執行攔截器的send 　　　　2 拿到c

>>阅读原文<<