[hotfix] Fix MysqlDebeziumTimeConverter miss timezone convert to time…

…stamp
apache · May 27, 2024 · e6dd9f1 · e6dd9f1
1 parent 8e8fd30
commit e6dd9f1
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java b/...-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java
@@ -174,11 +174,12 @@ private Object convertToTimestampWithTimezone(String columnType, Object timestam
             ZonedDateTime zonedDateTime = value.toInstant().atZone(zoneId);
             return ConvertTimeBceUtil.resolveEra(value, zonedDateTime.format(timestampFormatter));
         } else if (timestamp instanceof OffsetDateTime) {
-            OffsetDateTime value = (OffsetDateTime) timestamp;
+            OffsetDateTime value =
+                    ((OffsetDateTime) timestamp).toInstant().atZone(zoneId).toOffsetDateTime();
             return ConvertTimeBceUtil.resolveEra(
                     value.toLocalDate(), value.format(timestampFormatter));
         } else if (timestamp instanceof ZonedDateTime) {
-            ZonedDateTime zonedDateTime = (ZonedDateTime) timestamp;
+            ZonedDateTime zonedDateTime = ((ZonedDateTime) timestamp).toInstant().atZone(zoneId);
             return ConvertTimeBceUtil.resolveEra(
                     zonedDateTime.toLocalDate(), zonedDateTime.format(timestampFormatter));
         } else if (timestamp instanceof Instant) {