vstreamer: include gtid events in binlog commit queries

Signed-off-by: Max Englander <[email protected]>
vitessio · Oct 3, 2023 · 10132ec · 10132ec
1 parent 2f1fc13
commit 10132ec
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/go/vt/vttablet/tabletserver/vstreamer/vstreamer.go b/go/vt/vttablet/tabletserver/vstreamer/vstreamer.go
@@ -501,6 +501,9 @@ func (vs *vstreamer) parseEvent(ev mysql.BinlogEvent) ([]*binlogdatapb.VEvent, e
 			})
 		case sqlparser.StmtCommit:
 			vevents = append(vevents, &binlogdatapb.VEvent{
+				Type: binlogdatapb.VEventType_GTID,
+				Gtid: replication.EncodePosition(vs.pos),
+			}, &binlogdatapb.VEvent{
 				Type: binlogdatapb.VEventType_COMMIT,
 			})
 		case sqlparser.StmtDDL: