From a00b2efb1599cd78a7dcdc36757fb1f65f489068 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Thu, 19 Dec 2024 15:17:33 -0800
Subject: [PATCH] [Debezium] Include GTID in the Source payload (#1094)

---
 lib/cdc/util/relational_event.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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) {