カフカシリアライズ・デシリアライズを問題

Question

我々は、非同期再試行メカニズムに

を達成するためにプロデューサーのJavaの設定を使用しており、消費者の側に私たちがメッセージ駆動アダプタ（XML設定）を使用しています。

生産者側には、我々は

props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,MessageSerializer.class.getName()); 

プロデューサーに、我々はそれが唯一の

MessageSerializer実装をシリアライザインタフェースの実装をサポートするようエンコーダ実装を設定するためのオプションを持っていけない持っていることを確認しますシリアライザ

およびそれが唯一のデコーダインタフェースの実装をサポートするよう消費者側我々はデシリアライズオプションはありません。

<int-kafka:message-driven-channel-adapter 

       id="inAdapter" 
       channel="fromKafka" 
       connection-factory="connectionFactory" 
       key-decoder="kafkaKeyDecoder" 
       payload-decoder="kafkaDecoder"        
       topics="${topic.list}" 
       offset-manager="offsetManager"/> 

kafkaDecoderは実装デコーダ

Therforeどのようにあなたが上で提案してくださいすることができ、シリアル化中にエラーを取得これを対応して。

Answer 1

spring-integration-kafkaの古いバージョンを使用しています。それはもはやそのように設定されていません。現在のバージョンは2.1.0で、spring-kafka 1.1.2の上にあります。

統合コンポーネントは、spring-kafka referenceに記載されています。スプリングカフカ自体の設定は、その本の他の場所にあります。