tabular-io / iceberg-kafka-connect

Apache License 2.0
192 stars 41 forks source link

Respect optional/required in table create and schema evolution #115

Closed bryanck closed 11 months ago

bryanck commented 11 months ago

This PR updates auto table create so the required/optional flag from the record schema is applied. Also, changing a required field to optional will be applied to the Iceberg schema.

The optional flag from the record schema is ignored when it is incompatible. For example, adding a column always adds it as optional. Updating a field from optional to required is ignored.