From 1e7959cbbc0bc90df586b4c8780a628639132763 Mon Sep 17 00:00:00 2001 From: "yashi.srivastava" Date: Fri, 16 Jan 2026 19:15:28 +0530 Subject: [PATCH 1/4] Removing extra schema refresh calls --- .../postgresql/PostgresSnapshotChangeEventSource.java | 2 -- .../postgresql/PostgresStreamingChangeEventSource.java | 6 +----- 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java index 649096df585..14cacfa9d9d 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java @@ -106,7 +106,6 @@ protected void connectionCreated(RelationalSnapshotContext Date: Sat, 17 Jan 2026 00:05:40 +0530 Subject: [PATCH 2/4] Add fix --- .../postgresql/PostgresStreamingChangeEventSource.java | 2 ++ .../src/main/java/io/debezium/jdbc/JdbcConnection.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java index e1d3ac7430a..53cfb84ec2e 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java @@ -120,12 +120,14 @@ public void init(PostgresOffsetContext offsetContext) { } private void initSchema() { + LOGGER.info("Performing initial schema load"); try { taskContext.refreshSchema(connection, true); } catch (SQLException e) { throw new DebeziumException("Error while executing initial schema load", e); } + LOGGER.info("Completed initial schema load"); } @Override diff --git a/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java b/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java index ffac694d915..57cd435f453 100644 --- a/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java +++ b/debezium-core/src/main/java/io/debezium/jdbc/JdbcConnection.java @@ -1251,7 +1251,7 @@ public void readSchema(Tables tables, String databaseCatalog, String schemaNameP for (TableId includeTable : tableIds) { LOGGER.debug("Retrieving columns of table {}", includeTable); - Map> cols = getColumnsDetails(databaseCatalog, schemaNamePattern, includeTable.table(), tableFilter, + Map> cols = getColumnsDetails(databaseCatalog, includeTable.schema(), includeTable.table(), tableFilter, columnFilter, metadata, viewIds); columnsByTable.putAll(cols); } From f42ff0363a5f69a22bf426b66e6e117280014811 Mon Sep 17 00:00:00 2001 From: naveenmall11 Date: Sat, 17 Jan 2026 11:06:07 +0530 Subject: [PATCH 3/4] Add fix --- .../connector/mongodb/MongoDbSnapshotChangeEventSource.java | 1 + .../java/io/debezium/pipeline/ChangeEventSourceCoordinator.java | 1 + 2 files changed, 2 insertions(+) diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java index 0fcb7589328..b4fc76ae377 100644 --- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java +++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java @@ -99,6 +99,7 @@ protected SnapshotResult doExecute(ChangeEventSourceContex final MongoDbSnapshotContext mongoDbSnapshotContext = (MongoDbSnapshotContext) snapshotContext; LOGGER.info("Snapshot step 1 - Preparing"); + LOGGER.info("Logging here to know image build was successful") if (prevOffsetCtx != null && prevOffsetCtx.isInitialSnapshotRunning()) { LOGGER.info("Previous snapshot was cancelled before completion; a new snapshot will be taken."); } diff --git a/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java b/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java index 4241add1afc..3059780a1bf 100644 --- a/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java +++ b/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java @@ -337,6 +337,7 @@ protected void streamEvents(ChangeEventSourceContext context, P partition, O off } LOGGER.info("Starting streaming"); + LOGGER.info("Logging for validation"); streamingSource.execute(context, partition, offsetContext); LOGGER.info("Finished streaming"); } From 8cfd66e3976a97ee5ec023db0697a22461530b32 Mon Sep 17 00:00:00 2001 From: "yashi.srivastava" Date: Thu, 22 Jan 2026 15:26:08 +0530 Subject: [PATCH 4/4] Remove extra debug logs --- .../connector/mongodb/MongoDbSnapshotChangeEventSource.java | 1 - .../connector/postgresql/PostgresSnapshotChangeEventSource.java | 1 - .../java/io/debezium/pipeline/ChangeEventSourceCoordinator.java | 1 - 3 files changed, 3 deletions(-) diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java index b4fc76ae377..0fcb7589328 100644 --- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java +++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbSnapshotChangeEventSource.java @@ -99,7 +99,6 @@ protected SnapshotResult doExecute(ChangeEventSourceContex final MongoDbSnapshotContext mongoDbSnapshotContext = (MongoDbSnapshotContext) snapshotContext; LOGGER.info("Snapshot step 1 - Preparing"); - LOGGER.info("Logging here to know image build was successful") if (prevOffsetCtx != null && prevOffsetCtx.isInitialSnapshotRunning()) { LOGGER.info("Previous snapshot was cancelled before completion; a new snapshot will be taken."); } diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java index 14cacfa9d9d..d6eba4d24d6 100644 --- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java +++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresSnapshotChangeEventSource.java @@ -140,7 +140,6 @@ protected void lockTablesForSchemaSnapshot(ChangeEventSourceContext sourceContex LOGGER.info("Waiting a maximum of '{}' seconds for each table lock", lockTimeout.getSeconds()); jdbcConnection.executeWithoutCommitting(statements.toString()); - // now that we have the locks, refresh the schema } } diff --git a/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java b/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java index 3059780a1bf..4241add1afc 100644 --- a/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java +++ b/debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java @@ -337,7 +337,6 @@ protected void streamEvents(ChangeEventSourceContext context, P partition, O off } LOGGER.info("Starting streaming"); - LOGGER.info("Logging for validation"); streamingSource.execute(context, partition, offsetContext); LOGGER.info("Finished streaming"); }