Kafka 手动 ackMode MANUAL_IMMEDIATE 如果不确认怎么办
Kafka manual ackMode MANUAL_IMMEDIATE what if not acknowledge
我使用 Spring KafKa 并且我将 ackMode 设置为 MANUAL_IMMEDIATE
props.setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE);
情况是，出于某种原因，我的应用程序无法确认 (acknowledgment.acknowledge())，无一例外地错过了它。
1- 如何为错过的消息设置消费者重试
2- 如何配置在我配置的最大重试次数达到后调用函数
见the documentation about SeekToCurrentErrorHandlers。
当侦听器抛出异常时，错误处理程序将执行必要的查找并重新获取记录。您可以设置放弃前的尝试次数。
还有a DeadLetterPublishingRecoverer可以将失败的记录发送到另一个主题
我使用 Spring KafKa 并且我将 ackMode 设置为 MANUAL_IMMEDIATE
props.setAckMode(AbstractMessageListenerContainer.AckMode.MANUAL_IMMEDIATE);
情况是，出于某种原因，我的应用程序无法确认 (acknowledgment.acknowledge())，无一例外地错过了它。
1- 如何为错过的消息设置消费者重试 2- 如何配置在我配置的最大重试次数达到后调用函数
见the documentation about SeekToCurrentErrorHandlers。
当侦听器抛出异常时，错误处理程序将执行必要的查找并重新获取记录。您可以设置放弃前的尝试次数。
还有a DeadLetterPublishingRecoverer可以将失败的记录发送到另一个主题