Kafka 手动 ackMode MANUAL_IMMEDIATE 如果不确认怎么办

Question

我使用 Spring KafKa 并且我将 ackMode 设置为 MANUAL_IMMEDIATE

props.setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE);

情况是由于某种原因我的应用无法确认 (acknowledgment.acknowledge()) 并且毫无例外地错过了它。

1- 如何设置消费者重试错过的消息 2-如何配置在我配置的最大重试次数达到后调用函数

Answer 1

见the documentation about SeekToCurrentErrorHandlers。

当侦听器抛出异常时，错误处理程序将执行必要的查找并重新获取记录。您可以设置放弃前的尝试次数。

还有a DeadLetterPublishingRecoverer可以用来将失败的记录发送到另一个主题。