diff --git a/parse.go b/parse.go index 678490f..4bb417a 100644 --- a/parse.go +++ b/parse.go @@ -447,7 +447,7 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter if filter.SmallThan != 0 && filter.SmallThan < tx.Size { return true } - if tx.validSchemaCount == 0 { + if !filter.OnlyShowGtid && tx.validSchemaCount == 0 { return true } return fn(tx)