Spring-Cloud-StreamでKafkaに再接続を設定する方法

Question

私は、うまく動作するspring-cloud-streamの単純なKafkaコンシューマーを開発しました。 Kafkaがシャットダウンされると、フレームワークは自動再接続を実行します。問題は、再接続がフルスピードで試みられていることです（マシンでは毎秒約10回）。

質問：2回の試行、バックオフの間隔などの再接続の動作を設定するにはどうすればよいですか？

更新 マリアスが示唆したように私は問題を開いた。私は、これが私の希望する機能が存在しないというヒントとして取っています。答えてくれてありがとう！

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の問題を開いてください。上記のプロパティは、実際にエラーが発生した場合に再試行するためのものです。