[FLINK-17150] Introduce Canal format to support reading canal changelogs

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 15/Apr/20 03:29
• Updated: 15/May/20 15:10
• Resolved: 15/May/20 15:09

Description

Introduce CanalFormatFactory and CanalRowDeserializationSchema to read canal changelogs.

CREATE TABLE my_table (
  ...
) WITH (
 'connector'='...', -- e.g. 'kafka'
 'format'='canal-json',
 'canal-json.ignore-parse-errors'='true' -- default false
);