Spring Boot集成测试@EmbeddedKafka报Scala方法缺失错误求助

你遇到的NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;错误，本质是Scala版本不兼容搞出来的问题——Spring Kafka Test依赖的嵌入式Kafka需要特定版本的Scala类，而你项目里的Scala版本和它不匹配，导致方法找不到。

为什么会出现这个错误？ #

你用的Spring Boot 2.1.6.RELEASE默认依赖的Kafka客户端是2.0.1版本，对应的Scala版本是2.11。但如果你的项目里引入了其他依赖（比如自己指定了高版本的Kafka，或者别的库间接带了Scala 2.12+），就会出现这个问题——因为scala.Predef.refArrayOps这个方法在Scala 2.12里改了签名，旧版本的类找不到新版本的方法，反之亦然。

一步步排查解决： #

1. 先搞清楚项目里的Scala依赖冲突 #

用Gradle命令打出来依赖树，看看哪个依赖带了不兼容的Scala版本：

./gradlew dependencies

搜索scala-library，看看是不是同时出现了2.11和2.12两个版本，找到那个“搞事情”的依赖。

2. 强制统一Scala版本 #

在你的build.gradle里加一段配置，强制所有依赖用Scala 2.11（适配Spring Boot 2.1.x默认的Kafka版本）：

configurations.all {
    resolutionStrategy.eachDependency { details ->
        if (details.requested.group == 'org.scala-lang') {
            details.useVersion '2.11.12'
        }
    }
}

要是你想升级到Scala 2.12，那得同步升级Spring Boot和Spring Kafka版本——Spring Boot 2.1.x最高只支持Spring Kafka 2.2.x，对应Kafka 2.0.x；要用上Kafka 2.3+（Scala 2.12），得把Spring Boot升到2.2.x及以上。

3. 简化测试类的配置（优化点） #

你的测试类里那个静态代码块其实没必要留着，Spring Kafka Test会自动把Embedded Kafka的地址注入到spring.kafka.bootstrap-servers，删掉就行：

// 删掉这个多余的代码块
static {
    System.setProperty(EmbeddedKafkaBroker.BROKER_LIST_PROPERTY, "spring.kafka.bootstrap-servers");
}

另外，测试环境的配置最好单独放在src/test/resources/application.properties里，别和生产配置混在一起：

# src/test/resources/application.properties
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.group-id=test-group
# 不用手动指定bootstrap-servers，@EmbeddedKafka会自动覆盖

4. 确保版本兼容性 #

一定要注意Spring Boot、Spring Kafka、Kafka客户端的版本匹配，别乱搭：

• Spring Boot 2.1.x → Spring Kafka 2.2.x → Kafka 2.0.x
• Spring Boot 2.2.x → Spring Kafka 2.3.x → Kafka 2.2.x
• Spring Boot 2.3.x → Spring Kafka 2.5.x → Kafka 2.5.x

额外提醒 #

• 如果你的项目里手动引入了kafka-clients依赖，一定要保证它的版本和Spring Kafka依赖的版本一致，别自己瞎指定版本。
• 你用的@DirtiesContext注解是对的，它会在测试结束后销毁Spring上下文，避免不同测试之间的Embedded Kafka互相干扰。

内容的提问来源于stack exchange，提问作者agcr