[postgres] Fix postgres-cdc connector cannot recognize the optional option 'slot.name'

pull/365/head
dongdongking008 3 years ago committed by GitHub
parent e34ff84a43
commit d40765eb32
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -156,6 +156,7 @@ public class PostgreSQLTableFactory implements DynamicTableSourceFactory {
Set<ConfigOption<?>> options = new HashSet<>();
options.add(PORT);
options.add(DECODING_PLUGIN_NAME);
options.add(SLOT_NAME);
return options;
}
}

@ -96,6 +96,7 @@ public class PostgreSQLTableFactoryTest {
options.put("port", "5444");
options.put("decoding.plugin.name", "wal2json");
options.put("debezium.snapshot.mode", "never");
options.put("slot.name", "flink");
DynamicTableSource actualSource = createTableSource(options);
Properties dbzProperties = new Properties();

Loading…
Cancel
Save