CODEWITHSUNDEEP
apache-kafkaspring-integrationspring-kafka
sagar27
sagar27

Reputation: 3221

Spring Integration Kafka not working

I am trying to explore Spring Integration using Kafka and Spring Boot. I am following this tutorial Spring Integration and Kafka

I am using the dependencies provided in that document,but i am getting the following exception 

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

I think this is a jar mismatch issue, but i am not able to resolve it, i tried to change the version a lot but the combination is not working for me. Please find my below gradle dependencies.

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

Please do let me know if you need more details on this one.

Upvotes: 0

Views: 1179

Answers (2)

sagar27
sagar27

Reputation: 3221

I have used the following dependencies and they worked.

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

Upvotes: 0

Gary Russell
Gary Russell

Reputation: 174554

That's a very old article based on the 1.x version; the configuration has changed considerably - see the updated Spring Integration Kafka documentation in the spring-kafka reference manual.

Spring Integration Kafka (2.x) is now based on the Spring Kafka project.

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

There is also a sample application but it uses Java configuration, not XML.

Upvotes: 3

Related Questions