如何使用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