spring-integration-kafka 1.3.1.RELEASE : org.apache.kafka.common.serialization을 사용하는 모든 해결 방법은 무엇입니까?

Question

스프링 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> 

같은 일을하고 직렬화 최신 아파치 종속성을 사용하고있다

49 : 43,172 DeploymentsPathChildre 경고 -

가

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.x의), 이전 버전을 사용하는 경우에만 0.8.xx 카프카 클라이언트를 지원합니다.

스프링 통합 Kafka 2.x는 0.9.x.x -> 0.10.2.x를 지원합니다. 그것은 spring-kafka 프로젝트를 기반으로합니다.

새로운 스프링 통합 모듈을 기반으로 사용자 정의 소스를 만들어야합니다.

2.1.0.RELEASE는 spring-kafka 1.2.x 및 0.10.2.x 클라이언트에서 작동해야합니다.