具有 groupId `org.apache.bahir` 和 `org.apache.flink` 的两个 Flink Redis sink 依赖项有什么区别？

Question

我正在学习Flink。我尝试添加一个 Redis 接收器。在 official Flink doc, it links to a Apache Bahir doc 中，正在使用

<dependency>
    <groupId>org.apache.bahir</groupId>
    <artifactId>flink-connector-redis_2.11</artifactId>
    <version>1.1-SNAPSHOT</version>
</dependency>

但是，我在 Maven 找到了另一个 flink-connector-redis:

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-redis_2.11</artifactId>
    <version>1.1.5</version>
</dependency>

如您所见，groupId 不同。

我在他们的 website 找到了关于 Apache Bahir 的信息。

Apache Bahir provides extensions to multiple distributed analytic platforms, extending their reach with a diversity of streaming connectors and SQL data sources.

Currently, Bahir provides extensions for Apache Spark and Apache Flink.

这两个依赖有什么区别？建议首先使用哪个？谢谢！

Answer 1

flink-connector-redis 首先在 org.apache.flink 之下。然后它被移动到 org.apache.bahir 下并计划从那里维护。它是相同的代码库，但 bahir 快照在错误修复和增强方面确实有一些改进。

具有 groupId `org.apache.bahir` 和 `org.apache.flink` 的两个 Flink Redis sink 依赖项有什么区别？

What is the difference between two Flink Redis sink dependencies with groupId `org.apache.bahir` and `org.apache.flink`?

java

maven

redis

apache-flink

apache-bahir