为什么Redis源连接器不能用于Flink



我们希望在应用程序中使用现有的redis流,并使用Apache Flick处理消息,但找不到redis源连接器?Redis源连接器不可用的原因是什么?有什么限制吗?这在技术上是不可行的吗?

谢谢,Naresh

有一个Redis连接器,由于用户没有需求,它被移到了Apache Bahir。这也意味着Redis没有维护者或贡献者。您可以在Flink Dev邮件列表中找到讨论,网址为https://lists.apache.org/thread/7lxsl5s8wyjlfh1ygrznkw4pvdfn9hg5和处的(未维护(代码https://github.com/apache/bahir-flink/tree/master/flink-connector-redis

如果有用户想要贡献和维护Redis连接器,那么这很可能是可能的,因为Flink的所有连接器目前都被外部化到自己的存储库中。

更新:有一个新的Flink Redis连接器正在开发中,应该可以在https://github.com/apache/flink-connector-redis-streams

相关内容

  • 没有找到相关文章

最新更新