I think you may need to dump the upsert-kafka data to some storage that accepts cdc data, e.g. paimon or hudi. Then look up the data in these data lake storage. But Flink SQL doesn't support event time lookup join.
Best, Shengkai
I think you may need to dump the upsert-kafka data to some storage that accepts cdc data, e.g. paimon or hudi. Then look up the data in these data lake storage. But Flink SQL doesn't support event time lookup join.
Best, Shengkai