Time has been added by 8 hours after synchronized into kafka;

Source params { "name": "mysql-source-binlog-snapshot_year-jobId", "config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector", "snapshot.locking.mode": "none", "database.user": "", "database.server.id": "60761620", "database.history.kafka.topic": "dbhistory.mysql-source-binlog-snapshot_year-jobId", "database.history.kafka.bootstrap.servers": "10.37.253.81:9092,10.37.253.31:9092,10.37.253.80:9092", "database.server.name": "mysql-source-binlog-snapshot_year-jobId", "include.schema.changes": "false", "database.port": "3336", "enable.time.adjuster": "false", "table.whitelist": "connect_source_test.source_all_type_datetime_4", "decimal.handling.mode": "double", "database.serverTimezone": "Asia/Shanghai", "database.hostname": "", "database.password": "", "name": "mysql-source-binlog-snapshot_year-jobId", "database.whitelist": "connect_source_test", "time.precision.mode":"connect" } } Sink params: { "name": "mysql-sink-binlog-snapshot_year-taskId", "config": { "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector", "table.name.format": "sink_all_type_datetime_4", "transforms.unwrap.delete.handling.mode": "rewrite", "topics": "mysql-source-binlog-snapshot_year-jobId.connect_source_test.source_all_type_datetime_4", "db.timezone": "Asia/Shanghai", "name": "mysql-sink-binlog-snapshot_year-taskId", "transforms": "unwrap", "transforms.unwrap.type": "io.debezium.transforms.UnwrapFromEnvelope", "connection.url": "jdbc:MYSQL://10.37.253.19:3338/devds?user=**&password=***", "insert.mode": "upsert", "pk.mode": "record_value", "pk.fields": "int" } }