I actually thinking about this option as well . Im assuming that the correct way to implement it , is to integrate debezium embedded to source function ?
[1] https://github.com/debezium/debezium/tree/master/debezium-embedded On Wed, Jul 17, 2019 at 7:08 PM Flavio Pompermaier <pomperma...@okkam.it> wrote: > Hi to all, > I'd like to know whether it exists or not an example about how to leverage > Debezium as a CDC source and to feed a Flink Table (From MySQL for example). > > Best, > Flavio >
