Debezium MySQL Connector升级后枚举列告警及值为NULL问题求助

AI 小北

2026-6-28

Debezium MySQL Connector 1.7→2.5 枚举字段值为NULL的解决办法

问题根源

Debezium 2.x对MySQL枚举类型的默认处理逻辑和1.7.x存在差异：1.7.x允许直接读取枚举的索引值（Integer类型），而2.x默认要求读取枚举的字符串字面量。当字段值为NULL且JDBC类型匹配异常时，就会触发告警并最终输出NULL。

可行解决方案

启用旧版枚举处理逻辑
在连接器配置中添加mysql.enum.handling.mode=ordinal，让2.x版本沿用1.7.x的行为，直接读取枚举的索引值（Integer类型），无需转换为字符串。配置示例：
```
mysql.enum.handling.mode=ordinal
```
这是最快的兼容方案，无需修改数据库或自定义代码。
设置枚举字段非NULL默认值
若业务允许，给engine_type字段指定一个合法的枚举默认值，避免NULL导致的转换失败。执行SQL：
```
ALTER TABLE your_target_table MODIFY COLUMN engine_type ENUM('your_enum_value') CHARSET utf8 DEFAULT 'your_enum_value';
```

自定义字段值转换器
针对engine_type字段配置自定义转换器，处理Integer到枚举字符串的映射。在连接器配置中添加：

column.converters=engine_type:com.yourcompany.EnumIntegerToStringConverter

自定义转换器类示例（Java）：

public class EnumIntegerToStringConverter implements Converter<Integer, String> {
    @Override
    public String convert(Integer input) {
        // 根据枚举索引返回对应字符串，比如索引1对应"type1"
        return input == null ? null : "type1";
    }
}