1

問題なく動作する spring-cloud-stream を使用して、単純な Kafka コンシューマを開発しました。Kafka がシャットダウンされると、フレームワークは自動再接続も実行します。問題は、再接続が全速力で試行されることです (私のマシンでは 1 秒あたり約 10 回)。

質問: 2 回の試行間の間隔、バックオフなどに関して再接続動作を構成するにはどうすればよいですか?

更新 マリウスが提案したように、私は問題を開きました。これは、希望する機能が存在しないことを示唆しています。答えてくれてありがとう！

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

4

2 に答える 2

1

github の問題を開いてください。言及されているプロパティは、実際にはエラーの場合に再試行するためのものです。

于 2016-05-16T13:48:48.917 に答える
0

チャネル バインディング コンシューマー プロパティ (maxAttempts、backOffInitialInterval、backOffMaxInterval、backOffMultiplier) ごとに次のプレフィックスを付けて制御できます。

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

于 2016-05-16T11:05:43.327 に答える