4.1.1 消息發(fā)送流程?

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

KafkaProducer 發(fā)送消息流程

相關(guān)參數(shù)：?
batch.size：只有數(shù)據(jù)積累到 batch.size 之后，sender 才會發(fā)送數(shù)據(jù)。?
linger.ms：如果數(shù)據(jù)遲遲未達到 batch.size，sender 等待 linger.time 之后就會發(fā)送數(shù)據(jù)。?

4.1.2 異步發(fā)送 API?

1）導(dǎo)入依賴?

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

2）編寫代碼?
需要用到的類：?
KafkaProducer：需要創(chuàng)建一個生產(chǎn)者對象，用來發(fā)送數(shù)據(jù)?
ProducerConfig：獲取所需的一系列配置參數(shù)?
ProducerRecord：每條數(shù)據(jù)都要封裝成一個 ProducerRecord 對象?

?

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。