註解 KafkaListener批量接收訊息

2021-10-04 08:44:25 字數 776 閱讀 2095

之前介紹了如何在springboot中整合kafka,但是預設情況下,@kafkalistener都是一條一條消費,如果想要一次消費乙個批量的話,我們都知道,在kafka原生的api可以通過poll(num)來獲取一次獲取num條訊息:

那麼使用在springboot中使用@kafkalistener能否實現批量監聽呢?

看了spring-kafka的官方文件介紹,可以知道自1.1版本之後,@kafkalistener開始支援批量消費,只需要設定batchlistener引數為true。

@bean

public kafkalistenercontaine***ctory<?> batchfactory()

@bean

public mapconsumerconfigs()

開始監聽,批量消費後採用jpa的方式批量寫入資料庫,這裡containe***ctory = 「batchfactory」要指定為批量消費。

@kafkalistener(topics = "$", containe***ctory = "batchfactory")

public void listen(list> records, acknowledgment ack) catch (ioexception e)

if (null != b_zdrygk_zdryxx_fj_hcb1)

}try catch (exception e) finally

}

用 KafkaListener批量接收訊息

之前介紹了如何在springboot中整合kafka,但是預設情況下,kafkalistener都是一條一條消費,如果想要一次消費乙個批量的話,我們都知道,在kafka原生的api可以通過poll num 來獲取一次獲取num條訊息 那麼使用在springboot中使用 kafkalistener能...

Spring註解 Import註解

常用的匯入註解分類 註冊自己寫的類service dao controller可用包掃瞄 元件標註註解 controller service repository component bean 匯入的第三方包裡面的元件 import 快速給容器中匯入乙個元件 1 import 要匯入到容器中的元件 ...

Java 註解 元註解

retention retentionpolicy.source 註解僅存在於原始碼中,在class位元組碼檔案中不包含 retention retentionpolicy.class 預設的保留策略,註解會在class位元組碼檔案中存在,但執行時無法獲得,retention retentionpo...