Spring boot嵌入式Kafka集成抛出NoClassDefFoundError

Question

Spring Boot: 2.0.3版本

org.apache.kafka.kafka-streams: 1.0.0

Org.apache.kafka.kafka-客户端: 1.0.0

org.springframwork.kafka:spring-kafka-test:2.1.7.RELEASE

我有一个使用Kafka的Spring启动应用程序。我正在尝试使用https://blog.mimacom.com/testing-apache-kafka-with-spring-boot/来创建一个集成测试。

当我添加@EmbeddedKafka注解时，我在运行

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'kafkaEmbedded': Invocation of init method failed; nested exception is java.lang.NoClassDefFoundError: org/apache/kafka/common/record/RecordFormat
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1699) ~[spring-beans-5.0.8.RELEASE.jar:5.0.8.RELEASE]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:407) ~[spring-beans-5.0.8.RELEASE.jar:5.0.8.RELEASE]

有一些关于这个错误的谷歌结果，但是它们都是在旧的kafka客户端版本上，它们应该在我使用的版本中修复。

这看起来像是版本不匹配，但我不清楚我应该得到什么。

Answer 1

正如评论中所指出的，像这样的错误总是由于库版本不兼容造成的。下面的组合起作用了

spring boot: 2.1
spring-streams/spring-client: 2.0.1 (Using 2.2.0 creates some compatibility issues)
spring-kafka: 2.2.5.RELEASE