Hi All, In the current implementation of SeaTunnel, the connector is coupled with the computing engine, which results in a connector that needs to be implemented for each engine, and it is difficult to support multiple versions of the engine.
Through the questionnaire, it was found that users used multiple versions of Spark and Flink engines, and they also hoped that SeaTunnel would support Change Data Capture (CDC) connectors; Based on the above questions and needs, I created an improvement proposal: https://github.com/apache/incubator-seatunnel/issues/1608 Preliminary idea of Source and Sink API: https://github.com/apache/incubator-seatunnel/issues/1701 https://github.com/apache/incubator-seatunnel/issues/1704 Please discuss away! Zongwen Li
