flink + Kafka + JSON

Question

Я пытаюсь протестировать программу Flink, чтобы прочитать данные JSON, полученные от Kafka, используя этот класс JSONKeyValueDeserializationSchema. Однако мой 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>