關於Kafka(四) 生產者

發送消息 > 創建ProducerRecord對象，包含主題和內容，分區和鍵可選 > 序列化器將對象序列化以便網絡傳輸  > 數據傳輸到分區器，如果在ProducerRecord中指定了分區，則直接繼續發送，若未指定分區，則根據對象的鍵選擇分區 > 相同分區分到同一個消息批次中，併發送給服務器 > 服務器接收到消息後返回響應，如果成功寫入則返回RecordMetaData對象，包含主題和分區信息，

>>阅读原文<<