线上使用flink sql消费kafka topic canal json格式数据,发现有一些数据中有的时间字段值为0000-00-00 
00:00:00无法被解析,于是加了'canal-json.ignore-parse-errors = true' 
参数,作业是能够正常运行了,但同时我们也希望知道哪些数据解析失败以便发给上游业务系统去自查。想问一下除了ignore外,有办法将这些parse 
error数据输出到另外一个kafka topic吗?谢谢!

回复