[FLINK-27761] Add database and table field in canal-json sink

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table SQL / Ecosystem
• Assignee: Unassigned
• Reporter: Zhiwen Sun
• Created: 25/May/22 03:53
• Updated: 25/May/22 03:53

Description

When sink with canal-json format, only two fields in json root : data and type.

for example :

{"data":[{"order_status":"OK","order_amount":120,"dt":"2022-05-25"}],"type":"INSERT"}

If we want to output the data of multiple tables to the same topic, this will become inconvenient.

If the output contains database and table , we can continue to use the canal-json.database.include }}and {{canal-json.table.include to distinguish.