diff --git a/parse.go b/parse.go index 4ea535b..2a4e42a 100644 --- a/parse.go +++ b/parse.go @@ -491,7 +491,7 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter } } } - if !matched { + if matched { tx.Txs = txs } if len(tx.Txs) == 0 && matched {