spring-integration-kafka 1.3.1.RELEASE：org.apache.kafka.common.serializationを使用するための回避策はありますか？

Question

私はこの問題で遊ぶためにSpring XDを使用しています：

カフカのトピック（0.9バージョン）から受け取ったメッセージを逆シリアル化するための回避策はありますか？私はカフカのソースをasuming（私のストリームを実行すると、私は春・統合・カフカ1.3.1を維持するために、依存関係を変更しようと、この

 <dependency> 
     <groupId>org.springframework.integration</groupId> 
     <artifactId>spring-integration-kafka</artifactId> 
     <exclusions> 
      <exclusion> 
       <groupId>org.apache.kafka</groupId> 
       <artifactId>kafka-clients</artifactId> 
      </exclusion> 
      <exclusion> 
      <groupId>org.apache.kafka</groupId> 
      <artifactId>kafka_2.10</artifactId> 
      </exclusion> 
     </exclusions> 
    </dependency> 

    <dependency> 
     <groupId>org.springframework.kafka</groupId> 
     <artifactId>spring-kafka</artifactId> 
     <version>1.2.0.RELEASE</version> 
     <scope>compile</scope> 
    </dependency> 

    <dependency> 
     <groupId>org.apache.kafka</groupId> 
     <artifactId>kafka-clients</artifactId> 
     <version>0.10.2.0</version> 
     <scope>provided</scope> 
    </dependency> 

のようなものをやってシリアライズするために、最新のApacheの依存関係を使用している

49：：43172 DeploymentsPathChildreをWARN -

が

16：：：49プロパティkey.deserializerが有効でない 16は、43171がWARN DeploymentsPathChildrenCache-0 utils.VerifiableProperties |それは私がこれを取得しています展開されているログ） nCacheの-0 utils.VerifiableProperties - プロパティvalue.deserializerが有効

、明らかではありません。

2017-05-10T16:50:43-0400 1.3.0.RELEASE INFO task-scheduler-8 sink.probando_deserializer - {probando_topic={0=[[B@6fbfdb37]}} 

Answer 1

ザ・春XDは唯一、春の統合カフカ（1.1）の古いバージョンを使用しています0.8.xxのカフカクライアントをサポートしています。

スプリング統合Kafka 2.xは0.9.x.x - > 0.10.2.xをサポートします。それはspring-kafkaプロジェクトに基づいています。

新しいSpring Integrationモジュールに基づいてカスタムソースを作成する必要があります。

2.1.0.RELEASEはspring-kafka 1.2.xと0.10.2.xクライアントで動作するはずです。