花费 10 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