我想跟踪mongooplog并通过kafka传输它，但是有很多数据库和集合，我只想获取其中一个的更新数据。如果要从oplog中的所有操作记录中筛选出所需的操作记录，这可能会影响性能。所以我想问一个更好的解决方案。请给我一些建议。
ybzsozfc1#
目前还不清楚您使用的是什么工具，但是debezium支持这些工具来应用过滤器database.whitelist collection.whitelist 也不清楚什么会“影响性能”，因为您已经在读取完整的oplog，但是执行一个过滤器（意味着删除所有不符合条件的记录）应该不会有重大影响，因为布尔/regex检查通常会很快完成。
collection.whitelist
1条答案
按热度按时间ybzsozfc1#
目前还不清楚您使用的是什么工具，但是debezium支持这些工具来应用过滤器
database.whitelist
collection.whitelist也不清楚什么会“影响性能”，因为您已经在读取完整的oplog，但是执行一个过滤器（意味着删除所有不符合条件的记录）应该不会有重大影响，因为布尔/regex检查通常会很快完成。