Indeed Kafka connect is perfect but I think Flink could easily do the same
without much work..this is what I'm asking for..if anybody has never
thought about it
Anyone else having experience on this topic that could provide additional
feedback here?
On Thu, Jul 18, 2019 at 1:18 PM Flavio Pompermaier
wrote:
> I think that using Kafka to get CDC events is fine. The problem, in my
> case, is really about how to proceed:
> 1) do I need to create Flink tabl
I think that using Kafka to get CDC events is fine. The problem, in my
case, is really about how to proceed:
1) do I need to create Flink tables before reading CDC events or is there
a way to automatically creating Flink tables when they gets created via a
DDL event (assuming a filter on the name
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
wrote:
> Hi
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
