diff --git a/src/main/java/io/confluent/connect/jdbc/dialect/GenericDatabaseDialect.java b/src/main/java/io/confluent/connect/jdbc/dialect/GenericDatabaseDialect.java index c9ba718d3..d4f49bcda 100644 --- a/src/main/java/io/confluent/connect/jdbc/dialect/GenericDatabaseDialect.java +++ b/src/main/java/io/confluent/connect/jdbc/dialect/GenericDatabaseDialect.java @@ -488,8 +488,8 @@ protected String[] tableTypes( try (ResultSet rs = metadata.getTableTypes()) { while (rs.next()) { String tableType = rs.getString(1); - if (tableType != null && uppercaseTypes.contains(tableType.toUpperCase(Locale.ROOT))) { - matchingTableTypes.add(tableType); + if (tableType != null && uppercaseTypes.contains(tableType.trim().toUpperCase(Locale.ROOT))) { + matchingTableTypes.add(tableType.trim()); } } }