flink cdc使用streeam api 无法读取pg的增量数据

[kaiwangleo]

flink cdc使用streeam api 无法读取pg的增量数据

    SourceFunction<String> sourceFunction = PostgreSQLSource.<String>builder()
            .hostname(tool.get("pg.db.hostname"))
            .port(tool.getInt("pg.db.port"))
            .database(tool.get("pg.db.database"))
            .schemaList(tool.get("pg.db.schema"))
            .tableList(tool.get("pg.db.table"))
            .username(tool.get("pg.db.username"))
            .password(tool.get("pg.db.password"))
            .slotName(tool.get("pg.slot.name"))
            .decodingPluginName(tool.get("pg.plugin.name"))
            .deserializer(new CustomeDeserialization())
            .debeziumProperties(properties)
            .build();

已经开启checkpoint