我已经开发了一个简单的Kafka消费者与Spring云流的作品刚刚好。当Kafka被关闭时，框架甚至会自动重新连接。问题是尝试全速重新连接（在我的机器上大约每秒10次）。
问题：如何根据两次尝试之间的间隔、退避等配置重新连接行为？
马吕斯建议我更新一个问题。我认为这意味着我想要的特性不存在。谢谢你的回答！
https://github.com/spring-cloud/spring-cloud-stream/issues/541
我已经开发了一个简单的Kafka消费者与Spring云流的作品刚刚好。当Kafka被关闭时，框架甚至会自动重新连接。问题是尝试全速重新连接（在我的机器上大约每秒10次）。
问题：如何根据两次尝试之间的间隔、退避等配置重新连接行为？
马吕斯建议我更新一个问题。我认为这意味着我想要的特性不存在。谢谢你的回答！
https://github.com/spring-cloud/spring-cloud-stream/issues/541
2条答案
按热度按时间mqxuamgl1#
您可以通过带有前缀的每个通道绑定使用者属性（maxattempts、backoffinitialinterval、backoffmaxinterval、backoffmultiplier）来控制它们：
spring.cloud.stream.bindings.<channelName>.consumer.oyxsuwqo2#
请打开github问题。所提到的属性确实是为了在发生错误时重试。