使用此依赖关系时:
<dependency>
<groupId>net.manub</groupId>
<artifactId>scalatest-embedded-kafka_2.11</artifactId>
<version>2.0.0</version>
<scope>test</scope>
</dependency>
具有
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-sql-kafka-0-10_2.11</artifactId>
<version>2.3.0</version>
</dependency>
我遇到这个错误:
Cause: java.lang.ClassNotFoundException: org.apache.spark.sql.sources.v2.reader.SupportsScanUnsafeRow
试图找出哪个版本的“scalatest嵌入式Kafka”将与spark 2.3兼容。
有什么想法吗?
暂无答案!
目前还没有任何答案,快来回答吧!