Seems interesting. The article is a bit light on details around producers and schema management - how would this look like for existing protobufs going to Kafka? How does it handle types that might differ between proto and Iceberg or evolutions that are invalid in Iceberg, but are valid in proto (`oneof` comes to mind)?

fwiw, I've hand-written pretty much exactly this - proto on Kafka to Iceberg via Flink with dynamic source schemas - and things like schema evolution are a nightmare.