Flink: binlog transformation to multiple DTO and transformation method in flink
A newer to Kafka, Flink and Tidb.
Assume I have three source MySql tables s_a
, s_b
, and s_c
, and want to collect records to target TiDb table t_a
and t_b
in a realtime.
The mapping rules are