dinky icon indicating copy to clipboard operation
dinky copied to clipboard

[Feature][SQL Connector Format] Add Flink SQL format debezium-json-filter

Open Dkbei opened this issue 2 years ago • 0 comments

Search before asking

  • [X] I had searched in the issues and found no similar feature requirement.

Description

Flink Sql format debezium-json cannot support db include and table include option

Use case

Base Flink 1.14.X SQL format add debezium-json-filter extend ‘value.format' = 'debezium-json-filter' 'value.debezium-json-filter.ignore-parse-errors' = 'true', 'value.debezium-json-filter.database.include' = 'test', 'value.debezium-json-filter.table.include' = 'student|student_cpoy'

Related issues

No response

Are you willing to submit a PR?

  • [X] Yes I am willing to submit a PR!

Code of Conduct

Dkbei avatar Apr 01 '22 15:04 Dkbei