微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Micronaut @KafkaListener 在出现错误时丢弃轮询循环中的剩余消息

如何解决Micronaut @KafkaListener 在出现错误时丢弃轮询循环中的剩余消息

当使用@KafkaListener注解消费消息时,如果抛出异常,则轮询循环中剩余的消息将被忽略。

这意味着要实现“至少一次”消息处理语义,必须在侦听器方法中捕获所有异常。

KafkaConsumerProcessor 的

This line 是它使轮询循环出错的地方。 (这个类在上个月已经重构过,但问题仍然存在)

也许 Micronaut Kafka 团队中的某个人可以告诉我这是不是故意的?我在提出 GitHub 问题和在这里提出问题之间左右为难!我认为大多数使用侦听器的人都希望轮询循环中的下一条消息在出错时得到处理。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。