Skip to content

Commit 2ad7d65

Browse files
authored
[Feature][Connector]update pgsql-cdc publication for add table (apache#6309)
1 parent a09a5a2 commit 2ad7d65

File tree

5 files changed

+925
-2
lines changed

5 files changed

+925
-2
lines changed

.licenserc.yaml

+1
Original file line numberDiff line numberDiff line change
@@ -49,5 +49,6 @@ header:
4949
- 'seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/operation/AsyncOperation.java'
5050
- 'seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/AbstractSeaTunnelMessageTask.java'
5151
- 'seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/utils/PassiveCompletableFuture.java'
52+
- 'seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java'
5253

5354
comment: on-failure

LICENSE

+1
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,7 @@ seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apac
220220
seatunnel-connectors-v2/connector-cdc/connector-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium from https://github.com/ververica/flink-cdc-connectors
221221
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java from https://github.com/debezium/debezium
222222
seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb from https://github.com/ververica/flink-cdc-connectors
223+
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java from https://github.com/debezium/debezium
223224
generate_client_protocol.sh from https://github.com/hazelcast/hazelcast
224225
seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/utils/ExceptionUtil.java from https://github.com/hazelcast/hazelcast
225226
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/protocol/task/AbstractSeaTunnelMessageTask.java from https://github.com/hazelcast/hazelcast

seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorConfig.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -738,7 +738,7 @@ public static AutoCreateMode parse(String value, String defaultValue) {
738738
public static final Field PUBLICATION_AUTOCREATE_MODE =
739739
Field.create("publication.autocreate.mode")
740740
.withDisplayName("Publication Auto Create Mode")
741-
.withEnum(AutoCreateMode.class, AutoCreateMode.ALL_TABLES)
741+
.withEnum(AutoCreateMode.class, AutoCreateMode.FILTERED)
742742
.withWidth(Width.MEDIUM)
743743
.withImportance(Importance.MEDIUM)
744744
.withDescription(

0 commit comments

Comments
 (0)