[jira] [Created] (FLINK-17149) Introduce Debezium format to support reading debezium changelogs

["Jark Wu (Jira)" <ji...@apache.org>]

Jark Wu created FLINK-17149:
-------------------------------

             Summary: Introduce Debezium format to support reading debezium changelogs
                 Key: FLINK-17149
                 URL: https://issues.apache.org/jira/browse/FLINK-17149
             Project: Flink
          Issue Type: Sub-task
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
            Reporter: Jark Wu
             Fix For: 1.11.0


Introduce {{DebeziumFormatFactory}} and {{DebeziumRowDeserializationSchema}} to read debezium changelogs.


{code:sql}
CREATE TABLE my_table (
  ...
) WITH (
  'connector'='...',  -- e.g. 'kafka'
  'format'='debezium-json',
  'format.schema-include'='true' -- default false, Debeizum can be configured to include or exclude the message schema
  'format.ignore-parse-errors'='true' -- default false
);
{code}





--
This message was sent by Atlassian Jira
(v8.3.4#803005)