关于Canal的过滤机制

198 阅读 0 评论 131 点赞

我是靠谱客的博主健忘大门，这篇文章主要介绍关于Canal的过滤机制，现在分享给大家，希望可以做个参考。

服务端实例配置

canal.deployer-1.1.1/conf/example/instance.properties

canal.instance.filter.regex=.*\..*

客户端filter

connector.subscribe("o2o.pl_repayment_plan_user,o2o.orderdetail,o2o.o2o_third_orderdetail");

按照官方的解释

CanalConnector是否调用subscribe(filter)方法；有的话，filter需要和instance.properties的canal.instance.filter.regex一致，否则subscribe的filter会覆盖instance的配置，如果subscribe的filter是.*..*，那么相当于你消费了所有的更新数据【特别注意】

https://github.com/alibaba/canal/issues/1361

所以每次新增需要过滤的表的时候只需在自己的客户端修改代码即可