Hi everyone, I’m trying to build a real-time data pipeline using Flink CDC. My goal is to capture CDC data from Oracle and load it into PostgreSQL. However, based on the documentation I’ve found so far, PostgreSQL seems to be supported only as a source, not as a sink. Is there any way to work around this or achieve the same result? Thanks a lot for your help!

Flink has the JDBC connector that you can sink to PostgreSQL. It supports both DataStream and Table API. Check the doc.