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

Question

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

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

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

score 1 · Accepted Answer

1

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

于 2016-05-16T13:48:48.917 回答

score 0 · Accepted Answer

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

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

2 回答 2