我們使用KafkaTemplate.send(String data)這個(gè)方法發(fā)送消息到Kafka中，顯然這個(gè)方法并不能滿足我們系統(tǒng)的需求，那我們需要查看一下KafkaTemplate所實(shí)現(xiàn)的接口，看看還提供了什么方法。

當(dāng)我們發(fā)送消息到Kafka后，我們又怎么去確認(rèn)消息是否發(fā)送成功呢？這就涉及到KafkaTemplate的發(fā)送回調(diào)方法了。

接下來我們開始正式講解

查看發(fā)送接口

首先我們Ctrl+鼠標(biāo)左鍵進(jìn)入KafkaTemplate的源代碼中查看一下，可以看到有關(guān)發(fā)送的接口如下。

這里的參數(shù)還是比較簡單的，值得一提的事，方法中有個(gè)Long類型的時(shí)間戳(timestamp)參數(shù)，這是Kafka0.10版本提供的新功能，主要用來使用時(shí)間索引進(jìn)行查詢數(shù)據(jù)以及日志切分清除策略。

還有一個(gè)ProducerRecord參數(shù)，這個(gè)類其實(shí)就是整合了topic、partition、data等數(shù)據(jù)的消費(fèi)實(shí)體類。

topic：這里填寫的是Topic的名字

partition：這里填寫的是分區(qū)的id，其實(shí)也是就第幾個(gè)分區(qū)，id從0開始。表示指定發(fā)送到該分區(qū)中

timestamp：時(shí)間戳，一般默認(rèn)當(dāng)前時(shí)間戳

key：消息的鍵

data：消息的數(shù)據(jù)

ProducerRecord：消息對應(yīng)的封裝類，包含上述字段

Message>：Spring自帶的Message封裝類，包含消息及消息頭

Listena

總結(jié)

以上是生活随笔為你收集整理的kafkatemplate无法注入_Spring-Kafka（三）-KafkaTemplate发送消息及结果回调的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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