flinkcdc postgreSQL支持指定时间戳消费吗,?大佬们[阿里云实时计算 Flink版]

flinkcdc postgreSQL支持指定时间戳消费吗,大佬们

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
2 条回复 A 作者 M 管理员
  1. 根据最新的信息,Flink CDC 的 PostgreSQL Connector 目前还不支持直接指定时间戳进行消费。目前只有 MySQL 和 MongoDB 支持通过指定时间戳来进行数据同步。

    如果您需要在 Flink CDC 中使用 PostgreSQL Connector 并指定时间戳进行消费,目前的解决方案是通过下游来处理。您可以在 Flink CDC 将数据写入 Kafka 或其他消息队列后,使用下游的应用程序从指定时间戳开始消费数据。

    如果您确实需要在 PostgreSQL Connector 中支持指定时间戳消费的功能,可以考虑向 Flink CDC 社区提交一个相关的 issue,并提出您的需求。社区的开发者们会根据需求评估和计划相关的功能更新,并在后续版本中进行安排。

  2. 好像不支持 我也想有这样的能力 现在是通过下游来解决的。现在还不支持,记得就mysql 和 mongo支持,可以去社区开个issue,后面版本安排上,此回答整理自钉群“Flink CDC 社区”