0

我正在学习 Flink。我尝试添加一个 Redis 接收器。在官方 Flink 文档中,它链接到Apache Bahir 文档,该文档正在使用

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

但是,我flink-connector-redisMaven找到了另一个:

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

如您所见,这groupId是不同的。

我在他们的网站上找到了有关 Apache Bahir 的信息。

Apache Bahir 为多个分布式分析平台提供扩展,通过各种流连接器和 SQL 数据源扩展其范围。

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

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

4

1 回答 1

1

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

于 2021-08-16T07:36:30.660 回答