tongchenkeji 发表于:2023-7-2 17:18:330次点击 已关注取消关注 关注 私信 flinkcdc postgreSQL支持指定时间戳消费吗,?大佬们[阿里云实时计算 Flink版] 暂停朗读为您朗读 flinkcdc postgreSQL支持指定时间戳消费吗,大佬们 「点点赞赏,手留余香」 赞赏 还没有人赞赏,快来当第一个赞赏的人吧! 海报 实时计算Flink版# PostgreSQL175# 云原生数据库 PolarDB905# 关系型数据库2577# 实时计算 Flink版3179
Star时光AM 2023-11-27 18:43:04 1 根据最新的信息,Flink CDC 的 PostgreSQL Connector 目前还不支持直接指定时间戳进行消费。目前只有 MySQL 和 MongoDB 支持通过指定时间戳来进行数据同步。 如果您需要在 Flink CDC 中使用 PostgreSQL Connector 并指定时间戳进行消费,目前的解决方案是通过下游来处理。您可以在 Flink CDC 将数据写入 Kafka 或其他消息队列后,使用下游的应用程序从指定时间戳开始消费数据。 如果您确实需要在 PostgreSQL Connector 中支持指定时间戳消费的功能,可以考虑向 Flink CDC 社区提交一个相关的 issue,并提出您的需求。社区的开发者们会根据需求评估和计划相关的功能更新,并在后续版本中进行安排。
xin在这AM 2023-11-27 18:43:04 2 好像不支持 我也想有这样的能力 现在是通过下游来解决的。现在还不支持,记得就mysql 和 mongo支持,可以去社区开个issue,后面版本安排上,此回答整理自钉群“Flink CDC 社区”
根据最新的信息,Flink CDC 的 PostgreSQL Connector 目前还不支持直接指定时间戳进行消费。目前只有 MySQL 和 MongoDB 支持通过指定时间戳来进行数据同步。
如果您需要在 Flink CDC 中使用 PostgreSQL Connector 并指定时间戳进行消费,目前的解决方案是通过下游来处理。您可以在 Flink CDC 将数据写入 Kafka 或其他消息队列后,使用下游的应用程序从指定时间戳开始消费数据。
如果您确实需要在 PostgreSQL Connector 中支持指定时间戳消费的功能,可以考虑向 Flink CDC 社区提交一个相关的 issue,并提出您的需求。社区的开发者们会根据需求评估和计划相关的功能更新,并在后续版本中进行安排。
好像不支持 我也想有这样的能力 现在是通过下游来解决的。现在还不支持,记得就mysql 和 mongo支持,可以去社区开个issue,后面版本安排上,此回答整理自钉群“Flink CDC 社区”