代码之家 › 专栏 › 技术社区 › DilTeam

嵌入式卡夫卡和Spark 2.3版本不匹配问题

embedded-kafka scalatest apache-kafka apache-spark scala

0

DilTeam · 技术社区 · 6 年前

使用此依赖项时:

    <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

有什么想法吗?

0 回复 | 直到 6 年前