스프링 통합 Kafka가 작동하지 않습니다.

Question

저는 Kafka와 Spring Boot를 사용하여 Spring Integration을 탐색하려고합니다. 나는이 튜토리얼 내가 그 문서에서 제공되는 종속성을 사용하고 Spring Integration and Kafka

을 다음 있어요,하지만 난 다음 예외

Caused by: org.xml.sax.SAXParseException: cvc-complex-type.3.2.2: Attribute 'compression-codec' is not allowed to appear in element 'int-kafka:producer-configuration'. 

나는이 항아리 불일치 문제라고 생각을 얻고있다,하지만 난 해결할 수없는입니다 그것, 나는 버전을 많이 바꾸려고했지만 조합은 나를 위해 작동하지 않습니다. 내 아래 gradle 의존성을 찾으십시오.

compile('org.springframework.boot:spring-boot-starter-integration') 
compile('org.springframework.boot:spring-boot-starter') 
compile('org.apache.kafka:kafka_2.10:0.8.1.1') 
compile('org.springframework.integration:spring-integration-kafka:2.1.0.RELEASE') 
compile('org.springframework.integration:spring-integration-java-dsl:1.1.0.M1') 

이 부분에 대한 자세한 내용은 알려주십시오.

Answer 1

1.x 버전을 기반으로하는 매우 오래된 기사입니다. 구성이 상당히 변경되었습니다. spring-kafka 참조 설명서의 업데이트 된 Spring Integration Kafka 설명서를 참조하십시오.

스프링 통합 Kafka (2.x)는 현재 Spring Kafka 프로젝트를 기반으로합니다.

http://projects.spring.io/spring-kafka/

도 sample application있다하지만 자바 구성이 아닌 XML을 사용합니다.

Answer 2

다음 의존성을 사용했으며 효과가있었습니다.

compile('org.springframework.boot:spring-boot-starter') 
compile('org.springframework.integration:spring-integration-stream') 
compile('org.springframework.integration:spring-integration-kafka:2.1.0.RELEASE') 
compile('org.springframework.integration:spring-integration-java-dsl:1.1.0.M1')