diff --git a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java index 4e31812d4..e51b99637 100644 --- a/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java +++ b/debezium-core/src/main/java/io/debezium/relational/TableSchemaBuilder.java @@ -328,7 +328,7 @@ protected StructGenerator createValueGenerator(Schema schema, TableId tableId, L result.put(fields[i], value); } catch (final Exception e) { - Column col = columns.get(i); + Column col = columnsThatShouldBeAdded.get(i); String message = "Failed to properly convert data value for '{}.{}' of type {}"; if (eventConvertingFailureHandlingMode == null) { Loggings.logErrorAndTraceRecord(LOGGER, row,