[Feature][cdc] Handle Kafka CDC Debezium/Canal JSON from Flink SQL
Open
enhancement
- Dominant language
- Java
- Stars
- 3.4k
- Forks
- 1.4k
- Avg merge
- 1d 11h
- Merged PRs (30d)
- 396
Description
### Search before asking
- [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar.
### Motivation
At present, some Kafka CDC data comes from Flink SQL, and the CDC data produced by Flink SQL lacks a lot of information (even the data from Flink CDC lacks PK information). There is no schema or PK, and we should also have the ability to handle such scenarios in our Paimon Kafka CDC.
### Solution
_No response_
### Anything else?
_No response_
### Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.