Closed ismailsimsek closed 2 months ago
Just found the issue! it was the issue when generating GenericAppenderFactory in which full table schema was given, instead of key schema
GenericAppenderFactory
https://github.com/tabular-io/iceberg-kafka-connect/blob/595f835f5d9174e57660b12f407dabc84781e500/kafka-connect/src/test/java/io/tabular/iceberg/connect/data2/IcebergUtil.java#L96-L103
Just found the issue! it was the issue when generating
GenericAppenderFactory
in which full table schema was given, instead of key schemahttps://github.com/tabular-io/iceberg-kafka-connect/blob/595f835f5d9174e57660b12f407dabc84781e500/kafka-connect/src/test/java/io/tabular/iceberg/connect/data2/IcebergUtil.java#L96-L103