2017-12-01 15 views
0

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では期待できません。

誰か助けてくれますか?

答えて

1

syncのXML名前空間のサポートはnot added until 2.1でした。

2.0.xでは、KafkaProducerMessageHandler beanのプロパティをプログラムで設定する必要があります。

更新のためにEDIT

@Autowired 
private KafkaProducerMessageHandler handler; 

@PostConstruct 
public void init() { 
    this.handler.setSync(true); 
} 
+0

おかげゲイリー。しかし、この変数を設定することができないので、サンプルスニペットを提供してください。また、この変数をプログラムで設定すると、実際のユースケース「同期」を達成できると仮定します。 – kattoor

+1

私の編集を参照してください。複数のハンドラがある場合、Bean名で '@ Qualifier'を使用する必要があります。これはアダプタid +" .handler "です。 –

+0

更新いただきありがとうございます。このプロジェクトでXML設定を使用しているので、以下のコードスニペットでこのプロパティを設定できますか。 ' 「 – kattoor

関連する問題