我在Java測驗中創建了EmbeddedKafkaCluster，但得到了以下例外，但我已經添加了kafka_2.12的部署，其中有scala的部署。
Java版本：11
。添加了以下的部署項
<!--Kafka Embedded Cluster dependencies -->/span>
<dependency>
<groupId>/span>org.apache.kafka</groupId>
<artifactId>kafka_2.12</artifactId>
<version>${kafka.version}</version>
<classifier>test</classifier>
<scope>/span>test</scope>/span>
</dependency>/span>
<dependency>>
<groupId>/span>org.apache.kafka</groupId>
<artifactId>kafka_2.12</artifactId>
<version>${kafka.version}</version>
<scope>test</scope>
</dependency>/span>
例外：
java.lang.NoClassDefFoundError: scala/collection/convert/AsJavaExtensions
at java.base/java.lang.Class.forName0(Native Method)
at java.base/java.lang.Class.forName(Class.java:315)
at kafka.utils.Log4jControllerRegistration$.<clinit>(Logging.scala:28)
at kafka.zk.EmbeddedZookeeper.<init>(EmbeddedZookeeper.scala:37)
at org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.start(EmbeddedKafkaCluster.java：89)
at org.apache.kafka.streams.integration.utils.EmbeddedKafkaCluster.before(EmbeddedKafkaCluster.java：167)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:50)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java：306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:235)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:54)
原因是：java.lang.ClassNotFoundException：scala.collection.convert.AsJavaExtensions
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:582)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:178)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:521)
... 16 more
uj5u.com熱心網友回復：
升級到kafka_2.13解決了這個問題
。<!--Kafka Embedded Cluster dependencies -->/span>
<dependency>
<groupId>/span>org.apache.kafka</groupId>
<artifactId>kafka_2.13</artifactId>
<version>${kafka.version}</version>
<classifier>test</classifier>
<scope>/span>test</scope>/span>
</dependency>/span>
<dependency>>
<groupId>/span>org.apache.kafka</groupId>
<artifactId>kafka_2.13</artifactId>
<version>${kafka.version}</version>
<scope>test</scope>
</dependency>/span>
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/309097.html
標籤：