我正在学习 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-redis
在Maven找到了另一个:
<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 提供扩展。
这两个依赖有什么区别?建议先使用哪一个?谢谢!