Thanks Jerry for kicking off this thread, the idea makes sense to me, JDBC Sink is users’ need and Flink CDC project should support it soon.
Could you share your design docs(FLIP) firstly[1]？ And then we can continue the design discussion. Please feel free to ping me if you have any concerns about FLIP process or Flink CDC design part. Best, Leonard [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP+Template > 2024年5月15日 下午3:06，Jerry <kiss...@gmail.com> 写道： > > 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
