diff --git a/lib/cdc/util/relational_event.go b/lib/cdc/util/relational_event.go
index 69b6e4384..6dd805050 100644
--- a/lib/cdc/util/relational_event.go
+++ b/lib/cdc/util/relational_event.go
@@ -31,8 +31,9 @@ type Source struct {
 	Schema    string `json:"schema,omitempty"`
 	Table     string `json:"table"`
 	// MySQL specific
-	File string `json:"file,omitempty"`
-	Pos  int64  `json:"pos,omitempty"`
+	File string  `json:"file,omitempty"`
+	Pos  int64   `json:"pos,omitempty"`
+	Gtid *string `json:"gtid,omitempty"`
 }
 
 func (s *SchemaEventPayload) GetColumns() (*columns.Columns, error) {