【发布时间】:2022-11-10 09:48:26
【问题描述】:
我们希望在我们的应用程序中使用现有的 redis 流并使用 Apache Flick 处理消息,但找不到 Redis 源连接器? Redis源连接器不可用的任何原因?任何限制,在技术上不可行吗?
谢谢, 纳雷什
【问题讨论】:
标签: redis apache-flink flink-streaming redis-streams
我们希望在我们的应用程序中使用现有的 redis 流并使用 Apache Flick 处理消息,但找不到 Redis 源连接器? Redis源连接器不可用的任何原因?任何限制,在技术上不可行吗?
谢谢, 纳雷什
【问题讨论】:
标签: redis apache-flink flink-streaming redis-streams
有一个 Redis 连接器,由于用户没有需求,它被移到了 Apache Bahir。这也意味着 Redis 没有维护者或贡献者。你可以在https://lists.apache.org/thread/7lxsl5s8wyjlfh1ygrznkw4pvdfn9hg5 和https://github.com/apache/bahir-flink/tree/master/flink-connector-redis 找到有关 Flink Dev 邮件列表的讨论和(未维护的)代码
如果有用户想要贡献和维护一个 Redis 连接器,那很可能是有可能的,因为 Flink 的所有连接器目前都被外部化到它自己的存储库中。
【讨论】:
更新:有一个新的 Flink Redis 连接器正在开发中,它应该可以在https://github.com/apache/flink-connector-redis-streams 获得
【讨论】: