4.1.1 消息發送流程?

Kafka 的 Producer 發送消息采用的是異步發送的方式。在消息發送的過程中，涉及到了兩個線程——main 線程和 Sender 線程，以及一個線程共享變量——RecordAccumulator。main 線程將消息發送給 RecordAccumulator，Sender 線程不斷從 RecordAccumulator 中拉取消息發送到 Kafka broker。?

KafkaProducer 發送消息流程

相關參數：?
batch.size：只有數據積累到 batch.size 之后，sender 才會發送數據。?
linger.ms：如果數據遲遲未達到 batch.size，sender 等待 linger.time 之后就會發送數據。?

4.1.2 異步發送 API?

1）導入依賴?

<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.4.1</version> </dependency>

2）編寫代碼?
需要用到的類：?
KafkaProducer：需要創建一個生產者對象，用來發送數據?
ProducerConfig：獲取所需的一系列配置參數?
ProducerRecord：每條數據都要封裝成一個 ProducerRecord 對象?

?

總結

以上是生活随笔為你收集整理的大数据技术之 Kafka (第 4 章 Kafka API ) Producer API的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。