Spring Kafka Stream - 没有错误的未确认消息
Spring Kafka Stream - Unacknowledged message with no error
我正在使用 @StreamListener 来使用 Kafka 消息。
我已将 autoCommitOffset 设置为 false，将 autoCommitOnError 设置为 false。
我正在将所有失败的消息发送到 DLQ 主题以及 maxAttempt for failure。我在测试更改时遇到问题。
如果我既不确认已使用的消息也不抛出任何错误，会发生什么情况？ Kafka 会在一段时间后自动发送消息吗？
当我抛出错误时，重播开始，它会重试，直到我的 maxAttempt 配置和失败的消息转到 DLQ 主题。
如果消费者没有抛出任何错误并且没有确认消息，请告诉我 Kafka 是否支持重试。
What will happen if I am not acknowledging the consumed message and also not throwing any error ? Will Kafka send the message automatically after sometime ?
否；除非您不再处理任何消息，否则只有在您重新启动应用程序后才会重新发送。
Kafka 不会 "acknowledge" 离散消息；它只是将最后处理的偏移量存储在一个分区中。
我正在使用 @StreamListener 来使用 Kafka 消息。
我已将 autoCommitOffset 设置为 false，将 autoCommitOnError 设置为 false。
我正在将所有失败的消息发送到 DLQ 主题以及 maxAttempt for failure。我在测试更改时遇到问题。
如果我既不确认已使用的消息也不抛出任何错误，会发生什么情况？ Kafka 会在一段时间后自动发送消息吗？
当我抛出错误时，重播开始，它会重试，直到我的 maxAttempt 配置和失败的消息转到 DLQ 主题。
如果消费者没有抛出任何错误并且没有确认消息，请告诉我 Kafka 是否支持重试。
What will happen if I am not acknowledging the consumed message and also not throwing any error ? Will Kafka send the message automatically after sometime ?
否；除非您不再处理任何消息，否则只有在您重新启动应用程序后才会重新发送。
Kafka 不会 "acknowledge" 离散消息；它只是将最后处理的偏移量存储在一个分区中。