卡夫卡与蒙戈oplog连接



我想跟踪mongooplog并通过Kafka流式传输它.但是有很多数据库和集合,我只想获取其中一个的更新数据。如果要从oplog中的所有操作记录中过滤掉所需的操作记录,这可能会影响性能。所以我想要求一个更好的解决方案。请给我一些建议。

目前尚不清楚您使用的工具,但Debezium支持这些工具来应用过滤

  • database.whitelist
  • collection.whitelist

也不清楚什么会"影响性能",因为您已经在阅读完整的oplog,但是执行过滤器(意味着删除所有不符合条件的记录(应该不会产生重大影响,因为布尔/正则表达式检查通常很快就会完成。

相关内容

  • 没有找到相关文章

最新更新