I am learning Flink. I try to add a Redis sink. In the official Flink doc, it links to a Apache Bahir doc, which is using
<dependency>
<groupId>org.apache.bahir</groupId>
<artifactId>flink-connector-redis_2.11</artifactId>
<version>1.1-SNAPSHOT</version>
</dependency>
However, I found another flink-connector-redis
at Maven:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-redis_2.11</artifactId>
<version>1.1.5</version>
</dependency>
As you see the groupId
is different.
I found the info about Apache Bahir at their website.
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.
What is the difference between these two dependencies? Which one is recommended to use first? Thanks!
flink-connector-redis
was under org.apache.flink
first. Then it is moved under org.apache.bahir
and planned to maintain from there. It is the same codebase but bahir snapshots do have some improvements in both bug fixes and enhancements.