Hi, I'm trying to set up Flink with Debezium CDC Connector on AWS EMR, however, EMR only supports Flink 1.10.0, whereas Debezium Connector arrived in Flink 1.11.0, from looking at the documentation.
https://docs.aws.amazon.com/emr/latest/ReleaseGuide/emr-flink.html https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/formats/debezium.html I'm wondering what alternative solutions are available for connecting Debezium to Flink? Is there an open source Debezium connector that works with Flink 1.10.0? Could I potentially pull the code out for the 1.11.0 Debezium connector and compile it in my project using Flink 1.10.0 api? For context, I plan on doing some fairly complicated long lived stateful joins / materialization using the Table API over data ingested from Postgres and possibly MySQL. Appreciate any help, thanks! -- Rex Fenley | Software Engineer - Mobile and Backend Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | FOLLOW US <https://twitter.com/remindhq> | LIKE US <https://www.facebook.com/remindhq>
