[FLINK-38685][cdc-connector-postgresql] Redact sensitive information like password from logs (#4174)

tejanshrana · web-flow · commit 55aff6ec47f8 · 2025-11-18T13:30:38.000+08:00
diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java
@@ -167,8 +167,6 @@ public void configure(SourceSplitBase sourceSplitBase) {
                                     .with(DROP_SLOT_ON_STOP.name(), false)
                                     .build());
         }
-
-        LOG.info("PostgresConnectorConfig is {}", dbzConfig.getConfig().asProperties().toString());
         setDbzConnectorConfig(dbzConfig);
         PostgresConnectorConfig.SnapshotMode snapshotMode =
                 PostgresConnectorConfig.SnapshotMode.parse(

Original file line number	Diff line number	Diff line change
`@@ -167,8 +167,6 @@ public void configure(SourceSplitBase sourceSplitBase) {`
`167`	`167`	`.with(DROP_SLOT_ON_STOP.name(), false)`
`168`	`168`	`.build());`
`169`	`169`	`}`
`170`		`-`
`171`		`- LOG.info("PostgresConnectorConfig is {}", dbzConfig.getConfig().asProperties().toString());`
`172`	`170`	`setDbzConnectorConfig(dbzConfig);`
`173`	`171`	`PostgresConnectorConfig.SnapshotMode snapshotMode =`
`174`	`172`	`PostgresConnectorConfig.SnapshotMode.parse(`