如何在 Spring-Cloud-Stream 中配置重新连接到 Kafka答案

【问题标题】：How to configure reconnect to Kafka in Spring-Cloud-Stream如何在 Spring-Cloud-Stream 中配置重新连接到 Kafka
【发布时间】：2016-05-17 20:18:45
【问题描述】：

我用 spring-cloud-stream 开发了一个简单的 Kafka 消费者，它工作得很好。当 Kafka 关闭时，框架甚至会执行自动重新连接。问题是尝试全速重新连接（在我的机器上大约每秒 10 次）。

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

更新正如 Marius 建议的那样，我打开了一个问题。我认为这是我想要的功能不存在的暗示。谢谢你的回答！

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

【问题讨论】：

标签： java spring apache-kafka spring-cloud-stream

【解决方案1】：

请打开一个 github 问题。提到的属性确实是为了在发生错误时重试。

【讨论】：

【解决方案2】：

您可以通过带有前缀的每个通道绑定消费者属性（maxAttempts、backOffInitialInterval、backOffMaxInterval、backOffMultiplier）来控制它们：

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

【讨论】：

我知道这些属性，但没有一个像我要求的那样。它们用于控制消息的重新传递。