Debezium | Apache Flink Debezium is a CDC (Changelog Data Capture) tool that can stream changes in real-time from MySQL, PostgreSQL, Oracle, Microsoft SQL Server and many other databases into Kafka Debezium provides a unified format schema for changelog and supports to serialize messages using JSON and Apache Avro
CDC Connectors for Apache Flink - GitHub CDC Connectors for Apache Flink ® welcomes anyone that wants to help out in any way, whether that includes reporting problems, helping with documentation, or contributing code changes to fix bugs, add tests, or implement new features