如何在Spring-Cloud-Stream中配置與Kafka的重新連接

我已經開發出一款簡單的Kafka消費者，其彈簧雲流效果很好。當Kafka關閉時，框架甚至會執行自動重新連接。問題是重新連接嘗試全速（在我的機器上每秒大約10次）。如何在Spring-Cloud-Stream中配置與Kafka的重新連接

問題：如何根據兩次嘗試之間的間隔，退避等來配置重新連接行爲？

更新正如馬呂斯建議我開了一個問題。我將此作爲提示，表明我所需的功能不存在。謝謝你的回答！

您可以通過每通道與前綴綁定消費性質（maxAttempts，backOffInitialInterval，backOffMaxInterval，backOffMultiplier）進退自如：

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

2016-05-16 11:05:43

我知道這些屬性，但沒有像我要求的那些屬性。它們用於控制消息的重新傳遞。 –

請打開GitHub的問題。提到的屬性確實用於在發生錯誤時重試。

2016-05-16 13:48:48

完成，請參閱https://github.com/spring-cloud/spring-cloud-stream/issues/541 –

回答