flinkcdc????postgrep????????checkpoint????????????????????????

[Eleven]

????????????
PostgresSourceBuilder<Object&gt; builder = 
PostgresSourceBuilder.PostgresIncrementalSource
        .builder();builder.hostname(postgrepParam.getHostIp())
        .database(postgrepParam.getDatabaseName())
        .tableList(postgrepParam.getTablesName())
        .username(postgrepParam.getUsername())
        .password(postgrepParam.getPassword())
        .slotName(postgrepParam.getSlotName())//?????? ????????
        .decodingPluginName(postgrepParam.getDecodingPluginName()) //????????
        .deserializer(new PostgresDeserialization())
        .debeziumProperties(getDebeziumProperties())?6?7
        .startupOptions(StartupOptions.initial()).build();
??????tableList??????????table1??table2??????checkpoint????????????????????table3??????????????????????????????table1??table2????????????table3??????????????????????????




Eleven
1422399...@qq.com



&nbsp;