從源碼分析如何優雅的使用 Kafka 生產者

前言 在上文 設計一個百萬級的消息推送系統 中提到消息流轉採用的是 Kafka 作爲中間件。 其中有朋友諮詢在大量消息的情況下 Kakfa 是如何保證消息的高效及一致性呢？ 正好以這個問題結合 Kakfa 的源碼討論下如何正確、高效的發送消息。 內容較多，對源碼感興趣的朋友請繫好安全帶(源碼基於 v0.10.0.0 版本分析)。同時最好是有一定的 Kafka 使用經驗，知曉基本的用法。 簡單的消息

>>阅读原文<<