花費 12 ms
kafka:enable.auto.commit

一、背景 項目中有一個需求,是通過消費kafka的消息來處理數據,但是想要實現延遲消費的效果,於是想到了是否可以自己管理kafka的commit來實現,就是通過設置`enable.auto.commit`為False,預期是如果消費到了消息,但是不commit,kafka就會重新把消息放回隊列 ...

Fri Dec 27 09:03:00 CST 2019 0 6828

 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM