Flink CDC有没有用过mongocdc的,支不支持下游动态建表?

Flink CDC有没有用过mongocdc的,支不支持下游动态建表?

展开
收起
真的很搞笑 2023-11-15 08:21:58 96 分享 版权
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink CDC 目前不支持 MongoDB 的 CDC 功能。但是,您可以使用其他开源项目(例如 Debezium)来实现从 MongoDB 到 Flink CDC 的数据同步。
    关于下游动态建表的问题,Flink CDC 支持动态表功能,即在运行时添加或删除表,并且可以将这些更改应用于实时流处理作业中。因此,如果您希望在 Flink CDC 中动态创建表,请确保您的目标系统支持动态表功能,并配置相应的参数以启用该功能。
    需要注意的是,不同的目标系统对于动态表的支持程度和方式可能会有所不同。在某些情况下,您可能需要手动创建表,并在 Flink CDC 作业启动时指定它们。而在其他情况下,目标系统可能提供了自动创建表的功能,使得您可以轻松地在 Flink CDC 作业中动态创建表。

    2023-11-15 22:26:20
    赞同 展开评论
  • mongo没固定的表结构,动态建表暂时还不支持,此回答整理自钉群“Flink CDC 社区”

    2023-11-15 12:36:32
    赞同 展开评论
  • Apache Flink目前并不直接支持MongoDB的CDC(Change Data Capture)功能。但是,你可以使用Flink的Connector Framework来连接MongoDB并获取数据。

    对于下游动态建表的问题,Flink可以通过动态表注册的方式来实现。你可以在运行时动态地创建表,并在需要时将数据写入这些表。这种方式可以实现在运行时根据上游的数据变化动态地创建下游的目标表。

    然而,这种方式需要你在代码中实现,并且可能需要一些额外的配置和处理。具体的实现方式可能会根据你的具体需求和使用的Flink版本有所不同。

    2023-11-15 09:15:47
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理