添加MySQL TRIGGER后Debezium停止工作的故障问询

这个故障确实和你创建的TRIGGER直接相关，并非Debezium完全不支持触发器功能，而是你的触发器定义中的某些语法超出了当前使用的Debezium版本的SQL解析器处理能力，导致解析触发器DDL时失败，进而让连接器停止工作。

具体原因 #

从报错信息里的io.debezium.text.ParsingException: no viable alternative at input可以看出，Debezium的SQL解析器无法处理你触发器的这段定义：

CREATE DEFINER=`root`@`%` TRIGGER `gxapp_customer_db.BCAVAActivationApprovedReports_AI` AFTER INSERT ON `BCAVAActivationApprovedReports` FOR EACH ROW BEGIN DECLARE has_error BOOLEAN DEFAULT 0; DECLARE duplicate_key CONDITION FOR 1062; DECLARE foreign_key_violated CONDITION FOR 1216; DECLARE revision_inc INT

大概率是这几个点触发了解析问题：

• 触发器名称中包含了数据库名前缀（gxapp_customer_db.BCAVAActivationApprovedReports_AI），触发器本身属于对应库，无需在名称里指定跨库标识
• DEFINER子句的写法可能超出了解析器的兼容范围
• 触发器体内连续的多变量+自定义条件声明组合，在旧版本Debezium中可能存在解析bug

可行的解决方案 #

• 调整触发器定义：
  1. 移除DEFINER子句，用当前有权限的用户创建触发器（如果业务允许）
  2. 修改触发器名称，去掉数据库名前缀，直接使用BCAVAActivationApprovedReports_AI
  3. 可以尝试将触发器体内的DECLARE语句拆分换行（虽然是单行写法，但解析器可能对换行后的格式更友好）
• 升级Debezium版本：
  如果你使用的是较旧的Debezium版本（比如1.x系列），建议升级到最新的稳定版（2.x及以上），新版本对MySQL触发器的DDL解析兼容性做了大量优化，很多旧版本的解析bug已经被修复
• 临时规避方案：
  如果暂时无法修改触发器或升级版本，可以在Debezium连接器配置中添加include.query=false，这个配置会让连接器跳过DDL语句的解析步骤，但注意这会影响其他DDL操作的捕获，仅作为临时应急方案使用

补充说明 #

Debezium并非完全不支持MySQL触发器，绝大多数常规的触发器定义都能被正常处理，只有包含特殊语法的触发器才会触发解析器的兼容性问题，这类问题在新版本中已经得到了较多修复。

内容的提问来源于stack exchange，提问作者kevinp1005