How to use Flink with Kafka 0.10.1.0?

Question

Does Flink Kafka support 0.10.1.0?

I saw that there is flink-connector-kafka-0.10, but I can not see it in the latest version of flink.

I am currently using

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

Answer 1

The next small version of Flink, Flink 1.2.0, will contain a connector for Kafka 0.10.x (see JIRA issue ).

The freeze function for 1.2.0 occurred a few days ago. Flink 1.2.0 will be released after testing and voting in the community, hopefully in January 2017.

Answer 2

I am currently running Flink 1.1.4 using Kafka 0.10.0.0 using Kafka Connector 0.9_2.10

<dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-streaming-java_2.11</artifactId>
        <version>1.1.4</version>
        <scope>provided</scope>
    </dependency>

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