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 fc57a0d6d..1a4b336ee 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 @@ -189,7 +189,7 @@ protected void readTableStructure(ChangeEventSourceContext sourceContext, throw new InterruptedException("Interrupted while reading structure of schema " + schema); } - LOGGER.info("Reading structure of schema '{}'", snapshotContext.catalogName); + LOGGER.info("Reading structure of schema '{}' of catalog '{}'", schema, snapshotContext.catalogName); jdbcConnection.readSchema( snapshotContext.tables, snapshotContext.catalogName,