0

私は2つのアプリケーションをしましたspring.cloud.stream.kafka.binder.defaultBrokerPort。 すべてうまくいきます。私はカフカバインダーが接続可能なZooKeeperのノードのリストを定義する spring.cloud.stream.kafka.binder.zkNodesspring.cloud.stream.kafka.binder.defaultZkPort 参照マニュアルにおいて春の雲の流れと飼育係

私の理解では、アプリケーションをkafkaに接続するだけです。 それは使用可能なときに私に説明することができますか、私は動物園の相対的なプロパティを定義する必要があるユースケースを与えることができます。

答えて

2

Zookeeperは、パーティション数や同時インスタンス数などのバインダーオプションを使用して、カフカバインダーがトピックを自動的に作成できるようにするために使用されます(ブローカーに依存するのではなく)。この機能が不要な場合は、トピックの自動作成を無効にすることができます。 ここでの説明を参照してください:https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/37

これは1.1以降に利用できる機能です。 1.0でZookeeperは0.8のSimpleConsumerクライアントに必要でした。

関連する問題