Spring集成Kafka不工作

watbbzwu 于 2021-06-08 发布在 Kafka

关注(0)|答案(2)|浏览(348)

我正在尝试使用kafka和springboot来探索spring集成。我遵循这个教程 Spring 集成和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'.

我认为这是一个jar不匹配的问题，但我不能解决它，我试图改变版本很多，但组合不适合我。请找到我下面的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')

如果你需要更多的细节，请告诉我。

apache-kafka spring-kafka spring-integration

来源：https://stackoverflow.com/questions/44069679/spring-integration-kafka-not-working

2条答案

按热度按时间

bvhaajcl1#

这是一篇基于1.x版本的非常老的文章；配置发生了很大的变化-请参阅SpringKafka参考手册中更新的SpringIntegrationKafka文档。
SpringIntegrationKafka（2.x）现在基于SpringKafka项目。
http://projects.spring.io/spring-kafka/
还有一个示例应用程序，但它使用java配置，而不是xml。

赞(0）回复(0）举报 2021-06-09

pbgvytdp2#

我使用了以下依赖项，它们很有效。

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

赞(0）回复(0）举报 2021-06-09

我来回答

Spring集成Kafka不工作

2条答案

相关问题

热门标签

最新问答