【发布时间】：2020-12-28 00:04:20
【问题描述】：
使用@EmbeddedKafka(topics = { "checkins" })时
我收到一个错误
Caused by: java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce
at kafka.utils.TestUtils.tempDir(TestUtils.scala)
at org.springframework.kafka.test.EmbeddedKafkaBroker$EmbeddedZookeeper.<init>(EmbeddedKafkaBroker.java:738)
at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet(EmbeddedKafkaBroker.java:291)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1853)
at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1790)
我正在使用 spring boot 2.3.3.RELEASE
我的 gradle 看起来像
compile("io.confluent:kafka-json-serializer:$confluentJsonVersion")
compile ("org.apache.kafka:kafka-clients: $kafkaVersion")
implementation ("org.springframework.boot:spring-boot-starter-validation")
implementation("org.springframework.kafka:spring-kafak:$springKafkaVersion")
implementation "org.apache.kafka:kafka-clients:$kafkaVersion"
testImplementation("org.springframework.kafka:spring-kafka-test:$springKafkaVersion")
testImplementation("org.apache.kafka:kafka_2.13:$kafkaVersion")
testImplementation("org.apache.kafka:kafka_2.13:$kafkaVersion:test")
testImplementation ("org.apache.kafka:kafka-clients:$kafkaVersion:test")
【问题讨论】：
-
注意：如果
kafka-clients已经被提及为编译的依赖项，则不需要将其作为测试依赖项
标签： scala spring-boot apache-kafka spring-kafka spring-kafka-test