Re: Flink + Kafka Dynamic Table

2021-07-07 Thread Arvid Heise
> is table E. When record a1 in table A changes to a1’, corresponding > results in table D and E should also be changed. > > > I consider to use flink + kafka dynamic table to solve this. But > there’s a potential problem: > > > - records in medical field must not be lost. >

Flink + Kafka Dynamic Table

2021-07-05 Thread vtygoss
table E. When record a1 in table A changes to a1’, corresponding results in table D and E should also be changed. I consider to use flink + kafka dynamic table to solve this. But there’s a potential problem: - records in medical field must not be lost. - kafka event is append-only, and kafka