flink + Kafka + JSON

Question

私はこのJSONKeyValueDeserializationSchemaクラスを使用してKafkaから来たJSONデータを読み込むためにFlinkプログラムをテストしようとしています。しかし、私の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>