私はspring-cloud-starter-stream-kafkaとspring-cloud-stream jarを使用しています春のブートアプリケーションでカフカのために。spring-cloud-starter-stream-kafkaはspring.boot.cloud.stream.bindings.output.destinationに提供されたトピックを作成しません
jarのバージョンは1.1.1.RELEASEであり、Testという名前のproducerを作成しています。次の例は、application.ymlファイルです。
spring.boot.cloud.stream.bindings.output:
destination: Test
content-type: application/octet-stream
producer:
headerMode: raw
requiredGroups: testConsumerGroup
問題は、我々は代わりにテストトピックを作成する(ドッカー-COMPOSEを使用して)ドッカーでアプリケーションを実行するとき、それはトピックとして「出力」を作成している場合があります。 kafkaについて私はwurstmeister/kafka(Tag 0.9.0.1-1)の画像とwurstmeister/zookeeperを使用しています。 プロパティの更新を試みましたが、機能していません。
更新:デバッグはbindingServicePropertiesは、「出力」
これらの「時々」が発生した時期を特定しましたか? –
それは本当にランダムなものです。ですから、今私はカフカのイメージの異なるバージョンを試しています。 – Niks