如果我们在 Kafka Listener 中使用 return 语句会发生什么？
What happens if we use return statement inside Kafka Listener?
我有一个批量消费消息的 Kafka 监听器。我也在使用手动提交。如果任何一条消息有问题，我正在使用 return 语句而不提交偏移量（我想再次处理所有这些消息）。
我的问题是-
在 Kafka Listener 中使用 return 语句有副作用吗？
再次消费相同的消息需要多长时间？
我正在使用 Spring Kafka 和 SpringBoot。
如果您只是不提交偏移量，则不会再次传送该消息。
见。
使用 SeekToCurrentErrorHandler 并抛出异常。
任何 return 值都将被忽略，除非该方法用 @SendTo 注释（对于 request/reply 处理）。
我有一个批量消费消息的 Kafka 监听器。我也在使用手动提交。如果任何一条消息有问题，我正在使用 return 语句而不提交偏移量（我想再次处理所有这些消息）。
我的问题是-
在 Kafka Listener 中使用 return 语句有副作用吗？ 再次消费相同的消息需要多长时间？
我正在使用 Spring Kafka 和 SpringBoot。
如果您只是不提交偏移量，则不会再次传送该消息。
见
使用 SeekToCurrentErrorHandler 并抛出异常。
任何 return 值都将被忽略，除非该方法用 @SendTo 注释（对于 request/reply 处理）。