Avro Format

    The Apache Avro format allows to read and write Avro data based on an Avro schema. Currently, the Avro schema is derived from table schema.

    Here is an example to create a table using Kafka connector and Avro format.

    2.   item_id BIGINT,
    3.   category_id BIGINT,
    4.   behavior STRING,
    5.   ts TIMESTAMP(3)
    6. ) WITH (
    7.  'topic' = 'user_behavior',
    8.  'properties.bootstrap.servers' = 'localhost:9092',
    9.  'properties.group.id' = 'testGroup',
    10.  'format' = 'avro'
    11. )

    In addition to the types listed above, Flink supports reading/writing nullable types. Flink maps nullable types to Avro union(something, null), where is the Avro type converted from Flink type.