Spring Integration Kafka funktioniert nicht

Question

Ich versuche Spring Integration mit Kafka und Spring Boot zu erkunden. Ich verfolge dieses Tutorial Spring Integration and Kafka

ich die Abhängigkeiten in diesem Dokument verwenden, aber ich bin immer die folgende Ausnahme

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'. 

Ich denke, das ein Glas Mismatch-Problem ist, aber ich bin nicht in der Lage zu lösen Ich habe versucht, die Version sehr zu ändern, aber die Kombination funktioniert nicht für mich. Bitte finden Sie meine untenstehenden Abhängigkeiten.

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') 

Bitte lassen Sie mich wissen, wenn Sie weitere Informationen zu diesem benötigen.

Answer 1

Das ist ein sehr alter Artikel basiert auf der 1.x-Version; Die Konfiguration hat sich erheblich geändert - siehe die aktualisierte Spring Integration Kafka Dokumentation im Spring-Kafka Referenzhandbuch.

Frühling Integration Kafka (2.x) ist nun auf dem Frühling Kafka-Projekt.

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

Es gibt auch eine sample application aber es nutzt Java-Konfiguration, nicht XML.

Answer 2

Ich habe die folgenden Abhängigkeiten verwendet und sie haben funktioniert.

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')