@ -494,6 +494,9 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter
if matched {
tx.Txs = txs
}
if !matched && len(filter.IncludeTables) > 0 {
return true
if len(tx.Txs) == 0 && matched {