[Feature][Connector-V2] connector-kafka source support data conversion extracted by kafka connect source
Purpose of this pull request
#4137
Check list
- [ ] Code changed are covered with tests, or it does not need tests for reason:
- [ ] If any new Jar binary package adding in your PR, please add License Notice according New License Guide
- [ ] If necessary, please update the documentation to describe the new feature. https://github.com/apache/incubator-seatunnel/tree/dev/docs
- [ ] If you are contributing the connector code, please check that the following files are updated:
- Update change log that in connector document. For more details you can refer to connector-v2
- Update plugin-mapping.properties and add new connector information in it
- Update the pom file of seatunnel-dist
- [ ] Update the
release-note.
@hailin0 @TyrantLucifer
@hailin0 @TyrantLucifer
Hi @sunxiaojian , Overall LGTM, thank you for your contribution of Apache SeaTunnel, but unfortunately this current pull request overlaps in functionality with #3981, don't worry, your proposed solution and implementation approach are better. This pull request can be merged after #3981. Please be patient and wait for good news. Once there are new updates, I will ping you on this page.
@hailin0 PTAL
@sunxiaojian please resolve the conflict
@sunxiaojian please resolve the conflict
@hailin0 done
@sunxiaojian please resolve the conflict
@hailin0 done
@sunxiaojian Duplicate with https://github.com/apache/seatunnel/pull/5066 feature?
@sunxiaojian please resolve the conflict
@hailin0 done
@sunxiaojian Duplicate with #5066 feature?
@hailin0 It is also compatible with debezium and can be removed
check ci
@hailin0 PTAL
CI error is not related to this modification