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)
