diff --git a/parse.go b/parse.go index a256ffe..879ebc6 100644 --- a/parse.go +++ b/parse.go @@ -358,8 +358,6 @@ func parseBinlogWithFilter(r io.Reader, parse *replication.BinlogParser, filter } includeMap[v] = true } - } else { - includeMap["*.*"] = true } if len(filter.ExcludeTables) != 0 { for _, v := range filter.ExcludeTables {