如何使用JdbcSinkConnector将boolean字段转换为CHAR(1)类型字段

架构老林

2026-10-6

JdbcSinkConnector boolean转CHAR(1)的最优实现方案

方案1：使用内置Expression SMT（优先推荐，无需自定义代码）

如果你的Kafka Connect集群版本在2.6及以上，直接用官方内置的Expression单消息转换组件（SMT）即可完成转换，性能损耗极低，维护成本最小。

配置示例：

假设Topic中布尔字段名为is_valid，对应数据库CHAR(1)字段也为is_valid，在JdbcSinkConnector的配置文件中添加如下配置：

# 注册SMT组件，自定义命名为boolToChar
transforms=boolToChar
# 指定SMT作用于消息Value，类型为内置Expression
transforms.boolToChar.type=org.apache.kafka.connect.transforms.Expression$Value
# 编写转换逻辑：true映射为Y，false映射为N，空值保留
transforms.boolToChar.expression=case when is_valid = true then 'Y' when is_valid = false then 'N' else null end
# 指定输出字段名，直接覆盖原字段即可
transforms.boolToChar.field=is_valid

方案2：自定义SMT（适配低版本Kafka Connect）

如果集群版本低于2.6没有内置Expression SMT，轻量自定义SMT是最优选择，避免业务逻辑侵入上游生产端或数据库层。
核心实现逻辑示例：

@Override
public R apply(R record) {
    Struct value = (Struct) record.value();
    Boolean originVal = value.getBoolean("is_valid");
    String targetVal = null;
    if (Boolean.TRUE.equals(originVal)) {
        targetVal = "Y";
    } else if (Boolean.FALSE.equals(originVal)) {
        targetVal = "N";
    }
    Struct newValue = value.put("is_valid", targetVal);
    return newRecord(record, newValue);
}

将自定义SMT打包后放入Kafka Connect的插件目录，再按照普通SMT的方式配置到连接器即可。