apache-kafka – 如何使用Flink与Kafka 0.10.1.0？

2019年7月28日 204次阅读

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>

最佳答案 Flink的下一个次要版本Flink 1.2.0将包含Kafka 0.10.x的连接器(见
JIRA issue).

几天前,1.2.0的功能冻结发生了. Flink 1.2.0将在测试和社区投票后发布,希望在2017年1月.

点赞