2017-11-14 10 views
1

私は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は、「出力」

+0

これらの「時々」が発生した時期を特定しましたか? –

+0

それは本当にランダムなものです。ですから、今私はカフカのイメージの異なるバージョンを試しています。 – Niks

答えて

0

ライブラリのこのバージョンはバグを持っているように見えますようバインディングので、春の雲の流れが作成されたトピックを保持していないことを知って取得した後。そこで、ライブラリのバージョンを更新し、現在は正常に動作しています。

関連する問題