0

我过去使用过与 spring 应用程序的 kafka 集成，并且已经实现了重试机制。但是我们的团队决定启动一个 micronaut 服务，因为我们发现了一些不错的好处。

我添加了 micronaut-kafka 依赖项并设置了一个监听器。问题是，如果一条消息导致我的侦听器抛出异常，则会记录异常但提交偏移量。

有没有办法为每条消息配置重试次数？

4

0 回答 0