我有一个Kafka侦听器，它可以批量使用消息。我也在使用手动提交。如果其中任何一条消息有问题，我将使用return语句而不是提交偏移量（我想再次处理所有这些消息）。我的问题是-在kafka监听器中使用return语句是否有副作用？同样的消息需要多长时间才能再次被消费？我用SpringKafka和Spring Boot。
uelo1irk1#
如果不提交偏移量，则不会再次传递消息。看看这个答案。使用 SeekToCurrentErrorHandler 并抛出一个异常。任何返回值都将被忽略，除非用 @SendTo （用于请求/回复处理）。
SeekToCurrentErrorHandler
@SendTo
1条答案
按热度按时间uelo1irk1#
如果不提交偏移量，则不会再次传递消息。
看看这个答案。
使用
SeekToCurrentErrorHandler并抛出一个异常。任何返回值都将被忽略，除非用
@SendTo（用于请求/回复处理）。