diff --git a/go/cmd/vt_binlog_server/vt_binlog_server.go b/go/cmd/vt_binlog_server/vt_binlog_server.go
index <HASH>..<HASH> 100644
--- a/go/cmd/vt_binlog_server/vt_binlog_server.go
+++ b/go/cmd/vt_binlog_server/vt_binlog_server.go
@@ -431,7 +431,9 @@ func (blp *Blp) parseXid(line []byte) {
 
 func (blp *Blp) parseGroupId(line []byte) {
 	rem := bytes.SplitN(line, mysqlctl.BINLOG_GROUP_ID, 2)
-	groupId, err := strconv.ParseUint(string(rem[1]), 10, 64)
+	rem2 := bytes.SplitN(rem[1], mysqlctl.SPACE, 2)
+	groupIdStr := strings.TrimSpace(string(rem2[0]))
+	groupId, err := strconv.ParseUint(groupIdStr, 10, 64)
 	if err != nil {
 		panic(NewBinlogParseError(fmt.Sprintf("Error in extracting group_id %v, sql %v", err, string(line))))
 	}
Fixed group_id parsing.