这家伙太懒,什么都没留下
遗憾,kafka没有延迟功能的。
请问下如何通过kafka实现延迟队列呢
嗯。
所以说我只要引入类似于AWS sqs中死信队列的机制,把失败的消息发送到死信队列里面,当前消息正常提交,然后按照我上面的步骤的化,就可以保证消息只消费一次了吧
kafka是按offset的顺序消费的,因为一个客户端对应一个分区,如果客户端业务失败了,不提交当前的offset,后面的消息就无法消费了。如果提交,就跳过了。