ultimatech67

kafka verson: 3.2.2 debezium verson:1.9.6 需要修改convertDateTime方法、判断是否是java.sql.Timestamp、并进行转换 ```java /** private String convertDateTime(Object input) { if (input instanceof LocalDateTime) { return datetimeFormatter.format((LocalDateTime) input); } if (input instanceof java.sql.Timestamp) { Date date =...

 Yes、 kafka and debezium 2.1 timestamp  converter、It has been used in the project ------------------ 原始邮件 ------------------ 发件人: "holmofy/debezium-datetime-converter" ***@***.***>; 发送时间: 2023年2月23日(星期四) 凌晨1:52 ***@***.***>; ***@***.******@***.***>; 主题: Re: [holmofy/debezium-datetime-converter] timestamp类型的处理 (#2) Hello @ultimatech67 Thanks for identifying this....

``` package com.darcytech.debezium.converter; import io.debezium.spi.converter.CustomConverter; import io.debezium.spi.converter.RelationalColumn; import lombok.extern.slf4j.Slf4j; import org.apache.kafka.connect.data.SchemaBuilder; import java.time.*; import java.time.format.DateTimeFormatter; import java.util.Date; import java.util.Objects; import java.util.Optional; import java.util.Properties; import java.util.function.Consumer; /** * 处理Debezium时间转换的问题 * Debezium默认将MySQL中datetime类型转成UTC的时间戳({@link...