Flink CEP 只支持 Append-only（insert / update_before / update_after / delete 4类型的数据记录，除了insert 之外就会报这个错，Flink CDC 的 Source 会产生 update_after / delete 这两种数据）

• MySQL-CDC 增加 update_time，并以 （id，update_time） 为主键，写入 MySQL
• Flink CEP 支持 Kafka append only，jdbc 写入 kafka