MySQL schema变更异常

环境信息

canal version 1.1.4 mysql version 5.7

问题描述

WARN c.a.o.canal.parse.inbound.mysql.dbsync.LogEventConvert - table parser error : header { version: 1 logfileName: "mysql-bin.001103" logfileOffset: 17499676 serverId: 1244787869 serverenCode: "UTF-8" executeTime: 1599148927000 sourceType: MYSQL schemaName: "ips_taskanswer_vnnq_0030" tableName: "tb_student_paper_answer_correct_audios_3" eventLength: 4051 eventType: INSERT props { key: "rowsCount" value: "8" } }

期待结果

当一张MySQL table发生字段变更后，也能正常得到变更后的schema并且正常写入到kafka。

执行情况

当一张MySQL table发生字段变更后，会导致上面的异常，并且该条信息会被丢弃，之后在kafka中丢失。

原提问者GitHub用户