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