具有 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`?具有 groupId `org.apache.bahir` 和 `org.apache.flink` 的两个 Flink Redis sink 依赖项有什么区别？
【发布时间】：2021-10-17 23:49:18
【问题描述】：

我正在学习 Flink。我尝试添加一个 Redis 接收器。在official Flink doc 中，它链接到一个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 提供对多个分布式分析的扩展平台，通过各种流媒体扩展其覆盖范围连接器和 SQL 数据源。

目前，Bahir 为 Apache Spark 和 Apache 提供扩展 Flink。

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

【问题讨论】：

标签： java maven redis apache-flink apache-bahir

【解决方案1】：

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

【讨论】：