diff --git a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java
index 6841316ab..0e7e73713 100644
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/pgoutput/PgOutputMessageDecoder.java
@@ -338,9 +338,8 @@ private List<io.debezium.relational.Column> getTableColumnsFromDatabase(Postgres
             }
         }
         catch (SQLException e) {
-            LOGGER.warn("Failed to read column metadata for '{}.{}'", tableId.schema(), tableId.table());
+            LOGGER.error("Failed to read column metadata for '{}.{}'", tableId.schema(), tableId.table());
             throw e;
-            // todo: DBZ-766 Should this throw the exception or just log the warning?
         }
 
         return readColumns;