mapr-streamをバネ統合で使用していて、maprstreamのトピックにメッセージを送信するためにパブリッシャを作成しようとしています。私はhereと記されている以下のJarバージョン互換性マトリックスを使用しています。MaplStreamとSpring統合Kafkaプロデューサの問題
春統合カフカ - 2.0.1.RELEASE
春カフカ - 1.0.3.RELEASE
カフカ、クライアント - 0.9.0.0-MAPR-1607春に述べたように
私は春・統合・カフカ-2.0.1瓶、 を使用していますが、私は「同期」を言ってスキーマ検証の問題を取得していた場合、統合カフカdocumentationは、私がKafkaProducerMessageHandlerの「同期」プロパティを設定することができるはずですKafkaProducerMessageHandlerでは期待できません。
誰か助けてくれますか?
おかげゲイリー。しかし、この変数を設定することができないので、サンプルスニペットを提供してください。また、この変数をプログラムで設定すると、実際のユースケース「同期」を達成できると仮定します。 – kattoor
私の編集を参照してください。複数のハンドラがある場合、Bean名で '@ Qualifier'を使用する必要があります。これはアダプタid +" .handler "です。 –
更新いただきありがとうございます。このプロジェクトでXML設定を使用しているので、以下のコードスニペットでこのプロパティを設定できますか。 ' int-kafka:outbound-channel-adapter> 「 –
kattoor