我正在开发 Quarkus 应用程序并打算使用 Kafka 接收消息,但是如果应用程序在重试一定次数后无法访问 Kafka 代理,我想停止该应用程序。默认配置是无限次尝试重新连接。在Smallrye Reactive Messaging Kafka的文档中,它说我们可以使用kafka.retry-attempts
或mp.messaging.incoming.[channel-name].retry-attempts
配置重试次数。我已经尝试了这两种方法,但该应用程序仍在重新启动。
有没有人遇到过类似的问题,或者有人可以帮助我解决问题吗?