嵌入式kafka和spark 2.3版本不匹配问题

uqjltbpv  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(277)

使用此依赖关系时:

<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兼容。
有什么想法吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题