flink + Kafka + JSON

Question

我正在尝试使用这个JSONKeyValueDeserializationSchema类测试一个Flink程序来读取来自Kafka的JSON数据。然而，我的Intellij找不到这个类。我怀疑某些Maven依赖项丢失了，或者我使用了错误的依赖项。

我的pom.xml

    <dependencies>
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-java_2.11</artifactId>
        <version>0.10.2</version>
    </dependency>

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.11</artifactId>
        <version>1.1.1</version>
    </dependency>

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-clients_2.11</artifactId>
        <version>1.1.1</version>
    </dependency>

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-kafka-0.9_2.11</artifactId>
        <version>1.0.0</version>
    </dependency>

</dependencies>

下面的图片显示了我的Intellij抱怨。

​

​

我做错了什么？

谢谢

Answer 1

您需要在所有依赖项中使用相同的Flink版本。使用此依赖项部分应该可以修复问题

<dependencies>
<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.1.1</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.11</artifactId>
    <version>1.1.1</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-clients_2.11</artifactId>
    <version>1.1.1</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka-0.9_2.11</artifactId>
    <version>1.1.1</version>
</dependency>

</dependencies>