问题描述
当使用@KafkaListener注解消费消息时，如果抛出异常，则轮询循环中剩余的消息将被忽略。
这意味着要实现“至少一次”消息处理语义，必须在侦听器方法中捕获所有异常。
KafkaConsumerProcessor 的This line 是它使轮询循环出错的地方。 （这个类在上个月已经重构过，但问题仍然存在）
也许 Micronaut Kafka 团队中的某个人可以告诉我这是不是故意的？我在提出 GitHub 问题和在这里提出问题之间左右为难！我认为大多数使用侦听器的人都希望轮询循环中的下一条消息在出错时得到处理。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）