@KafkaListener(topics = {KafkaConstants.ORDER_CREATE_THIRD})
public void createListen(ConsumerRecord<?, ?> record, Acknowledgment ack) {
ack.acknowledge();
log.info("手動提交后==== 接受引數+++++++++++++++++++++++++++++++++++++++++++++++++++++");
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
springboot專案，如上代碼，接收到資料后直接提交確認了，按照我的理解，既然提交確認了，那么就會直接消費下一條資料，但實際情況是等到下面的睡眠結束后才會進行下一條資料消費。
springboot版本2.1.4，spring-kafka版本2.2.7
求問各位大佬，這是為什么？我想實作的是 手動提交確認后，下一條資料就進來消費了。
沒有積分了，實在不好意思
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/191127.html
標籤：非技術區
上一篇：求答案，我的極域2016豪華版教師機無法連接網路配接器？
下一篇：GTWR插件求助