Update codec.go

pingcap · Jan 6, 2025 · e650495 · e650495
1 parent d674b2d
commit e650495
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/sink/codec/debezium/codec.go b/pkg/sink/codec/debezium/codec.go
@@ -1393,7 +1393,9 @@ func (c *dbzCodec) EncodeDDLEvent(
 									jWriter.WriteIntField("position", pos+1)
 									jWriter.WriteBoolField("optional", !mysql.HasNotNullFlag(flag))
 
-									autoIncrementFlag := mysql.HasAutoIncrementFlag(flag) || mysql.HasOnUpdateNowFlag(flag) && mysql.HasNotNullFlag(flag)
+									updateNowTimestamp:= mysql.HasOnUpdateNowFlag(flag) && jdbcType == internal.JavaSQLTypeTIMESTAMP_WITH_TIMEZONE
+									autoIncrementFlag := mysql.HasAutoIncrementFlag(flag) || updateNowTimestamp
+
 									jWriter.WriteBoolField("autoIncremented", autoIncrementFlag)
 									jWriter.WriteBoolField("generated", autoIncrementFlag)
 								})