* 生產者將消息寫入到Broker * Producer直接發送消息到Broker上的Leader Partition * Producer客戶端自己根據分區策略（隨機分配、自定義分區算法等）控制著消息被推送到哪些Partition * Producer 可以以**同步**和**異步**的方式發送消息 * Batch推送提高效率 Producer 負責向 Kafka 主題發布（生產）消息，一個 Topic 可以有多個 Producer實例，其相互之間沒有協作關系。Producer 的 `send()` 方法用于發送消息，參數ProducerRecord 封裝了消息的內容：Topic、Partition、key、value 等信息。如果發送成功，返回的 RecordMetadata 中記錄了消息的偏移量(Offset)，如果發送失敗就會重試或者拋出異常。如下圖所示。 :-:  Producer 消息發送流程 Producer 以 **Batch 的方式**推送數據可以極大的提高處理效率，Kafka Producer 可以將消息在內存中累計到一定數量后作為一個 Batch 發送請求，Batch 的數量大小可以人為進行干預，通過增加 Batch 的大小，可以減少網絡請求和磁盤 IO 的次數，當然具體參數設置需要在效率和時效性方面做一個權衡。