Kafka手动确认模式手动\u立即如果不确认怎么办

drnojrws 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(600)

我使用SpringKafka和我设置ackmode为手动

props.setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE);

情况是，由于某种原因，我的应用程序无法确认( acknowledgment.acknowledge() )无一例外地错过了。
1-如何设置错过消息的使用者重试2-如何配置在达到我配置的最大重试次数后调用函数

1条答案

请参阅有关的文档 SeekToCurrentErrorHandler s。
当侦听器抛出异常时，错误处理程序将执行必要的查找并重新获取记录。您可以设置放弃前的尝试次数。
还有一个 DeadLetterPublishingRecoverer 可用于将失败的记录发送到另一个主题。