Проблема несоответствия встроенной версии Kafka и Spark 2.3 - PullRequest
Новая
       52

Проблема несоответствия встроенной версии Kafka и Spark 2.3

1 голос
/ 28 мая 2020

Когда я использую эту зависимость: 

    <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-embedded-kafka' будет работать со Spark 2.3.

Есть идеи?

...