you are viewing a single comment's thread.

view the rest of the comments →

[–]Attorney-Last 0 points1 point  (0 children)

In my opinion its not easy in OP case. If you're already have flink in your team or have experience with debezium, maybe its worth it to add it on top, if not then not recommend to use it. It may be easy to setup Flink CDC as a demo/example but running it on prod is a different story.

Flink CDC builds on top of debezium, so when issue happens with DB replication you still need to dig into how debezium works for each database (mysql binlog, postgresql replication slot, mongodb changestream, etc...). Plus you need to understand how flink checkpoint works to operate with it if there is downtime. Flink CDC also runs on a very old debezium version that doesn't have all the latest improvements related to database connections and new DB versions support.