CSV Format

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

    Here is an example to create a table using Kafka connector and CSV 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' = 'csv',
    11.  'csv.ignore-parse-errors' = 'true',
    12. )

    Flink CSV format uses to parse and generate CSV string.