如果我们在 Kafka Listener 中使用 return 语句会发生什么？答案

【问题标题】：What happens if we use return statement inside Kafka Listener?如果我们在 Kafka Listener 中使用 return 语句会发生什么？
【发布时间】：2021-04-26 21:56:08
【问题描述】：

我有一个批量消费消息的 Kafka 侦听器。我也在使用手动提交。如果任何一条消息有问题，我将使用 return 语句而不提交偏移量（我想再次处理所有消息）。

我的问题是-

在 Kafka Listener 中使用 return 语句有副作用吗？再次消费相同的消息需要多长时间？

我正在使用 Spring Kafka 和 SpringBoot。

【问题讨论】：

标签： java spring spring-boot apache-kafka spring-kafka

【解决方案1】：

如果你只是不提交偏移量，消息将不会再次传递。

见this answer。

使用SeekToCurrentErrorHandler 并引发异常。

除非方法用@SendTo 注释（用于请求/回复处理），否则任何返回值都将被忽略。

【讨论】：