dinky
dinky copied to clipboard
[Feature][SQL Connector Format] Add Flink SQL format debezium-json-filter
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
- [X] I agree to follow this project's Code of Conduct