???????????? PostgresSourceBuilder<Object> 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