From 10132ec86377b93c4cf6a19edcbf27b7dcc479c1 Mon Sep 17 00:00:00 2001 From: Max Englander Date: Tue, 3 Oct 2023 13:00:15 +0100 Subject: [PATCH] vstreamer: include gtid events in binlog commit queries Signed-off-by: Max Englander --- go/vt/vttablet/tabletserver/vstreamer/vstreamer.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/go/vt/vttablet/tabletserver/vstreamer/vstreamer.go b/go/vt/vttablet/tabletserver/vstreamer/vstreamer.go index c538d6d3871..fc5cdbbd704 100644 --- 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: