如何使用Flink和Kafka 0.10.1.0？

Question

Flink是否支持Kafka 0.10.1.0？

我看到有一个flink-connector-kafka-0.10，但我无法在flink最新版本中看到它。

目前我使用

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

Answer 1

弗林克，弗林克1.2.0，下一次次版本将包括卡夫卡0.10.x连接器（见JIRA issue）。

1.2.0的功能冻结发生在几天前。弗林克1.2.0将测试和社区投票后公布，希望能在2017年一月

Answer 2

目前，我使用的是卡夫卡连接器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> 

运行弗林克1.1.4与卡夫卡0.10.0.0