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