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

當我們發送消息到Kafka后，我們又怎么去確認消息是否發送成功呢？這就涉及到KafkaTemplate的發送回調方法了。

接下來我們開始正式講解

查看發送接口

首先我們Ctrl+鼠標左鍵進入KafkaTemplate的源代碼中查看一下，可以看到有關發送的接口如下。

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

還有一個ProducerRecord參數，這個類其實就是整合了topic、partition、data等數據的消費實體類。

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

partition：這里填寫的是分區的id，其實也是就第幾個分區，id從0開始。表示指定發送到該分區中

timestamp：時間戳，一般默認當前時間戳

key：消息的鍵

data：消息的數據

ProducerRecord：消息對應的封裝類，包含上述字段

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

Listena

總結

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

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