@ -491,8 +491,10 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
}
if !matched {
tx.Txs = txs
if len(txs) == 0 && matched {
if len(tx.Txs) == 0 && matched {
return true
return fn(tx)