從源碼理解 Kafka 的分區選擇策略[新的生產者發送消息分區選擇]

Kafka 中將 Topic 分爲 partition，消費者從 partition 中消費消息。消息是怎麼確定發住哪個 partition 呢？其實默認有兩種分區選擇策略： 消息 key 爲空時隨機選擇 消息 key 不爲空時，對 key 進行 HASH，然後對分區數取模 源碼分析 在 KafkaProducer 的 doSend 方法中調用了以下方法進行分區選擇，如果指定了分區，則直接使用指定

>>阅读原文<<