Skip to content

Commit b8a087b

Browse files
dongdongking008Jiabao-Sun
authored andcommitted
[postgres] Fix postgres-cdc connector cannot recognize the optional option 'slot.name'
1 parent 241b880 commit b8a087b

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

flink-connector-postgres-cdc/src/main/java/com/ververica/cdc/connectors/postgres/table/PostgreSQLTableFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,7 @@ public Set<ConfigOption<?>> optionalOptions() {
156156
Set<ConfigOption<?>> options = new HashSet<>();
157157
options.add(PORT);
158158
options.add(DECODING_PLUGIN_NAME);
159+
options.add(SLOT_NAME);
159160
return options;
160161
}
161162
}

flink-connector-postgres-cdc/src/test/java/com/ververica/cdc/connectors/postgres/table/PostgreSQLTableFactoryTest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@ public void testOptionalProperties() {
9696
options.put("port", "5444");
9797
options.put("decoding.plugin.name", "wal2json");
9898
options.put("debezium.snapshot.mode", "never");
99+
options.put("slot.name", "flink");
99100

100101
DynamicTableSource actualSource = createTableSource(options);
101102
Properties dbzProperties = new Properties();

0 commit comments

Comments
 (0)