这个问题可能是因为 FlinkCDC 的 Debezium connector 不支持 Postgres 分区表的快照模式为 never。在这种情况下,您可以尝试以下解决方案:

  1. 尝试将 Debezium 的快照模式设置为 always 或 initial,这些模式可以正常读取分区表的数据。

  2. 尝试使用 FlinkCDC 的 PostgreSQL connector,该 connector 可以正常读取 Postgres 分区表的数据。

  3. 如果以上解决方案都无法解决问题,您可以尝试使用其他的数据同步工具,例如 Apache Kafka Connect 或 Canal 等。这些工具都可以正常读取 Postgres 分区表的数据。

flinkcdc 读取postgre的分区表debeziumsnapshotmode配置为never无法获取数据

原文地址: https://www.cveoy.top/t/topic/fIs7 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录