[jira] [Created] (FLINK-39605) Implement Avro Variant Confluent format for dynamic schema deserialization

["Swapna Marru (Jira)" <ji...@apache.org>]

Swapna Marru created FLINK-39605:
------------------------------------

             Summary: Implement Avro Variant Confluent format for dynamic schema deserialization
                 Key: FLINK-39605
                 URL: https://issues.apache.org/jira/browse/FLINK-39605
             Project: Flink
          Issue Type: New Feature
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
            Reporter: Swapna Marru


Add a new deserialization format that can read Avro binary data from Confluent Schema Registry and convert it into Flink's VARIANT type. The existing avro-confluent format requires a fixed reader schema at table creation time. This format cannot be used if you want to deserialize the records with varying schemas. 

The new format should be able to use the writer schema dynamically per record — enabling schema-agnostic ingestion where the Avro schema varies across records.

Records are deserialized into VARIANT type column . Fields can later be accessed using VARIANT accessor methods. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)