如何在Spring-Cloud-Stream中配置与Kafka的重新连接

Question

我已经开发出一款简单的Kafka消费者，其弹簧云流效果很好。当Kafka关闭时，框架甚至会执行自动重新连接。问题是重新连接尝试全速（在我的机器上每秒大约10次）。

问题：如何根据两次尝试之间的间隔，退避等来配置重新连接行为？

更新 正如马吕斯建议我开了一个问题。我将此作为提示，表明我所需的功能不存在。谢谢你的回答！

https://github.com/spring-cloud/spring-cloud-stream/issues/541

Answer 1

您可以通过每通道与前缀绑定消费性质（maxAttempts，backOffInitialInterval，backOffMaxInterval，backOffMultiplier）进退自如：

spring.cloud.stream.bindings.<channelName>.consumer.

Answer 2

请打开GitHub的问题。提到的属性确实用于在发生错误时重试。