diff --git a/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java b/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java index 43c7944b..2fe01c19 100644 --- a/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java +++ b/kafka-connect/src/main/java/io/tabular/iceberg/connect/data/SchemaUtils.java @@ -322,7 +322,7 @@ private Type doInferIcebergType(Object value) { } else if (value instanceof List) { List list = (List) value; if (list.isEmpty()) { - return null; + return ListType.ofOptional(nextId(), StringType.get()); } Optional elementType = inferIcebergType(list.get(0)); return elementType.map(type -> ListType.ofOptional(nextId(), type)).orElse(null);