之前介紹了如何在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...