MySQL中小于0100年的Datetime经Kafka转换后Timestamp异常

AI 小北

2026-8-17

问题描述

在MySQL的datetime列插入值0078-10-15 10:00:00.0000000，同步到Kafka后该数据的timestamp为277293600000，经转换对应日期为1978年10月15日10:00:00，但数据库中实际存储的是带世纪的0078-10-15 10:00:00.0000000
MySQL文档明确：两位年份值存在歧义解析规则——70-99会被解析为1970-1999，00-69解析为2000-2069，但此处存储的是四位年份的0078
年份大于0099时转换正常，timestamp为负数
已尝试调整time.precision.mode参数，问题仍未解决

Debezium连接器配置

{"name": "source-param-datetime","config": {
    "connector.class" : "io.debezium.connector.mysql.MySqlConnector",
    "database.hostname": "hostname",
    "database.port": "3306",
    "database.user": "user",
    "database.password": "password",
    "database.server.id" : "12",
    "database.server.name": "erp_pd",
    "database.include.list": "bgcrm_v21",
    "table.include.list": "bgcrm_v21.param_datetime",
    "database.history.kafka.bootstrap.servers": "server",
    "database.history.kafka.topic": "dbhistory.erp.param_datetime",
    "include.schema.changes": "false",
    "snapshot.mode": "schema_only",
    "snapshot.locking.mode" : "minimal_percona",
    "transforms": "unwrap",
    "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
    "transforms.unwrap.drop.tombstones" : "false",
    "key.converter":"io.confluent.connect.avro.AvroConverter",
    "key.converter.schema.registry.url":"http://localhost:8081",
    "value.converter":"io.confluent.connect.avro.AvroConverter",
    "value.converter.schema.registry.url":"http://localhost:8081",
    "name": "source-param-datetime"
}}