Debezium JDBC Sink连接器：MySQL TINYINT转PostgreSQL BOOLEAN方案咨询

一、TINYINT（布尔值）转BOOLEAN的实现 #

方法1：在Debezium MySQL源连接器中提前转换类型 #

在MySQL源连接器配置中添加字段转换逻辑，把存储布尔值的TINYINT字段转成Kafka消息中的BOOLEAN类型，让JDBC Sink直接匹配PostgreSQL的BOOLEAN列：

# MySQL源连接器核心配置
connector.class=io.debezium.connector.mysql.MySqlConnector
# ...其他基础配置（数据库地址、账号、同步表等）

# 配置字段转换
transforms=convertBoolean
transforms.convertBoolean.type=org.apache.kafka.connect.transforms.Cast$Value
transforms.convertBoolean.spec=your_boolean_column:boolean

替换your_boolean_column为实际存储布尔值的TINYINT列名，多列用逗号分隔（如col1:boolean,col2:boolean）

方法2：在JDBC Sink连接器中做类型转换 #

若源端无法修改，直接在Sink端配置转换，将Kafka消息中的INT8类型（对应MySQL TINYINT）转成BOOLEAN：

# PostgreSQL JDBC Sink核心配置
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector
connection.url=jdbc:postgresql://your-pg-host:5432/dbname
connection.user=pguser
connection.password=pgpass
auto.create=false
auto.evolve=false  # 关闭自动schema演化，避免修改禁用表结构的报错
# ...其他Sink配置（topics、table.name.format等）

# 配置类型转换
transforms=castBoolean
transforms.castBoolean.type=org.apache.kafka.connect.transforms.Cast$Value
transforms.castBoolean.spec=your_boolean_column:boolean

关键注意事项 #

• 确保PostgreSQL目标表的对应列已设为BOOLEAN类型
• 若TINYINT用1/0表示true/false，Cast转换器会自动完成映射；若为非0即真的规则，需额外自定义转换逻辑

二、MySQL BIGINT（时长）转PostgreSQL INTERVAL的参考方案 #

针对Django时长字段（MySQL用BIGINT存毫秒/微秒数），可沿用类似转换思路：

方法1：用转换器映射Duration类型 #

若BIGINT存储的是秒/毫秒数，用TimestampConverter将其转为Duration类型，PostgreSQL JDBC驱动会自动映射为INTERVAL：

transforms=convertInterval
transforms.convertInterval.type=org.apache.kafka.connect.transforms.TimestampConverter$Value
transforms.convertInterval.target.type=org.apache.kafka.connect.data.Duration
transforms.convertInterval.field=your_duration_column
transforms.convertInterval.format=MILLISECONDS  # 存储为秒则改为SECONDS

方法2：自定义逻辑转换（复杂场景） #

若需要更灵活的转换规则（如毫秒转HH:MI:SS格式INTERVAL），可通过KSQL预处理后再同步：

CREATE STREAM transformed_duration_stream AS
SELECT 
  other_columns,
  INTERVAL '1 MILLISECOND' * your_duration_column AS duration_interval
FROM source_stream;

让JDBC Sink消费转换后的KSQL流即可。

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