Hi all My name is ZhengjunZhou, an user and developer of FlinkCDC. In my recent projects, I realized that we could enhance the capabilities of Flink-CDC-Pipeline by introducing a JDBC Sink plugin, enabling FlinkCDC to directly output change data capture (CDC) to various JDBC-supported database systems.
Currently, while FlinkCDC offers support for a wide range of data sources, there is no direct solution for sinks, especially for common relational databases. I believe that adding a JDBC Sink plugin will significantly boost its applicability in data integration scenarios. Specifically, this plugin would allow users to configure database connections and stream data directly to SQL databases via the standard JDBC interface. This could be used for data migration tasks as well as real-time data synchronization. To further discuss this proposal and gather feedback from the community, I have prepared a preliminary design draft and hope to discuss it in detail in the upcoming community meeting. Please consider the potential value of this feature and provide your insights and guidance. Thank you for your time and consideration. I look forward to your active feedback and further discussion. [1] https://github.com/apache/flink-connector-jdbc
