温馨提示:本文翻译自stackoverflow.com,查看原文请点击:Spring Kafka Stream - Unacknowledged message with no error
apache-kafka spring-kafka stream consumer

Spring Kafka Stream - 未确认的消息,没有错误

发布于 2020-04-11 00:06:42

我使用@StreamListener消耗的Kafka消息。

我已autoCommitOffsetfalse,并autoCommitOnErrorfalse

我将所有失败的消息也发送给DLQ主题,以获取失败的maxAttempt。我在测试更改时有一个问题。

如果我不确认已使用的消息并且也没有引发任何错误,将会发生什么?Kafka会在一段时间后自动发送邮件吗?

当我抛出错误时,重播会启动,并且重试直到我的maxAttempt配置和失败的消息转到DLQ主题。

让我知道Kafka支持是否重试,如果使用者没有抛出任何错误并且没有确认消息。

查看更多

提问者
JPGS
被浏览
75
Gary Russell 2020-02-03 00:33

如果我不确认已使用的消息并且也没有引发任何错误,将会发生什么?Kafka会在一段时间后自动发送邮件吗?

没有; 除非您不再处理其他消息,否则即使重新启动应用程序,也只能重新交付。

Kafka不会“确认”离散消息。它只是将最后处理的偏移量存储在分区中。