Spring Cloud Data FlowでKafkaクライアントのタイムアウト設定を構成する方法はありますか？

Question

Spring Cloud Data Flowストリームを開始すると、さまざまなKafka関連のエラーが原因で、アプリケーションが自分のマシンに展開できないことがよくあります。例えば： org.springframework.cloud.stream.binder.BinderException: Cannot initialize binder [...] Caused by: kafka.common.KafkaException: fetching topic metadata for topics [Set(xxx)] from broker [List()] failed

しかし、私はまた、これを見てきました：両方の状況で kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0

を、カフカプロセスが実行されている（同様のZooKeeper）されたので、私は渡されたタイムアウトしきい値のいくつかの並べ替えがあるとし。

genericもKafka-specificも、タイムアウトオプションを提供していないようです。

私はカフカクライアントが諦めブローカーがなくなったと仮定している時間に影響を与える方法はありますか？

Answer 1

./bin/kafka-topics.shなどのkafkaツールコマンドを使用してトピック情報を取得できますか？可能なタイムアウトよりカフカ構成の問題のように見えます。あなたはカフカのプロデューサ/コンシューマ中（connect.timeout.msなど、のような）一般的なプロパティのいずれかを設定したい場合は

、あなたがspring.cloud.stream.kafka.bindings.<channelName>.<producer/consumer>.configuration.<propertyName>=<propertyValue>

Answer 2

経由でそれを行うことができ、カフカブローカーが正しく実行されなかったようですurトピックが同期しているかどうかを確認するには、 bin/kafka-topics.sh --describe --zookeeper <your zookeeper host>:2181を試してみてください。