diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/transforms/timescaledb/QueryInformationSchemaMetadata.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/transforms/timescaledb/QueryInformationSchemaMetadata.java
index 7e1528bfe..6b33b0c64 100644
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/transforms/timescaledb/QueryInformationSchemaMetadata.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/transforms/timescaledb/QueryInformationSchemaMetadata.java
@@ -93,8 +93,6 @@ private void loadTimescaleMetadata() {
                             new TableId(null, rs.getString(3), rs.getString(4)));
                 }
             });
-
-            connection.close();
         }
         catch (SQLException e) {
             throw new DebeziumException("Failed to read TimescaleDB metadata", e);