1. 使用flink cdc 读mysql 写clickhouse2. clickhouse使用CollapsingMergeTree sign 1 is a “state” row, -1 is a “cancel” row.3. 解决时间差8个小时问题

Caused by: org.apache.kafka.common.KafkaException: Received exception when fetching the next record from t_vpn-2. If needed, please seek past the record to continue consumption.Caused by: org.apache.k