diff --git a/parse.go b/parse.go index 2a4e42a..3e5f0f2 100644 --- a/parse.go +++ b/parse.go @@ -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 { return true }