Flink CDC读取PostgreSQL分区表时Debezium.snapshot.mode配置为never无法读取数据的解决方法
当使用Flink CDC读取PostgreSQL分区表时,将'debezium.snapshot.mode'配置为'never'无法读取数据的原因是,Debezium在读取分区表时需要使用必要的元数据来确定如何正确地处理分区。如果将'debezium.snapshot.mode'设置为'never',则Debezium将不会创建或使用必要的元数据,因此无法正确地读取数据。
解决办法是将'debezium.snapshot.mode'设置为'initial'或'initial_only',这将允许Debezium创建必要的元数据,并正确地读取数据。如果您不希望在每次启动Debezium时都进行快照,则可以选择'initial_only'模式,这将仅在Debezium首次启动时创建快照。
另外,如果您正在使用Flink CDC作为Debezium的客户端,请确保您的Flink版本支持在读取分区表时使用Debezium创建的元数据。如果您的Flink版本过低,则可能需要升级到最新版本。
原文地址: https://www.cveoy.top/t/topic/on12 著作权归作者所有。请勿转载和采集!