tabular-io / iceberg-kafka-connect

Apache License 2.0
192 stars 41 forks source link

Detect fields in sink record missing in table schema #93

Closed bryanck closed 11 months ago

bryanck commented 11 months ago

This PR adds detection of missing columns during the conversion of a sink record into a table row. This is the first step towards providing automatic schema evolution and auto table creation. The missing columns are not yet applied to the table schema, that will be added in a follow-up PR.