【 TiDB 使用环境】生产环境
【 TiDB 版本】5.4.0
【复现路径】做过哪些操作出现的问题
【遇到的问题:问题现象及影响】
已建好的ticdc投递到下游MySQL库,现在需要新增一个filter,过滤一张表,不再同步到下游,请问该如何操作?
tiup cdc cli changefeed create --pd=http://192.168.1.1:2379 --sink-uri=“mysql://xxx:xxx@192.168.1.2:4000/?worker-count=16&max-txn-row=5000” --changefeed-id=“tidb2mysql-replication-task111” --sort-engine=“unified”
看文档有 cdc cli changefeed update,但是我建changfeed的时候是没有使用配置文件的。
【资源配置】进入到 TiDB Dashboard -集群信息 (Cluster Info) -主机(Hosts) 截图此页面
【附件:截图/日志/监控】
1.在配置文件中,找到[filter]部分,这里可以新增或修改filter规则。
2.通过TiUP的相关命令来重启TiCDC服务,以应用新的配置文件。
3.重启TiCDC服务后,可以通过查看TiCDC的日志或使用TiCDC的命令行工具来验证filter规则是否生效。
设置filter要引入用任务配置文件的,具体可以参考一下官方文档
过滤规则定义了TiCDC应该捕获哪些表的变更。一个规则通常包含以下部分:
matcher:定义匹配哪些表的规则。
filter:定义过滤逻辑。
没有配置文件在update的时候也可以重新指定配置文件
tiup ctl:v8.2.0 cdc changefeed create --server=http://x.x.x.x:8300 --sink-uri=“kafka://x.x.x.x:9092/kafka-test?protocol=open-protocol” --config=/etc/ticdc/cdc-filter.toml --changefeed-id=“ticdc-kafka-changefeed”
这里有一个 --config 选择toml文件所在路径即可,我这个是同步到kafka的命令,但是过滤器用的文件是一样的
过滤器规则
Changefeed 日志过滤器 | PingCAP 文档中心
小龙虾爱大龙虾
(Minghao Ren)
9
这里介绍不了我
(持续学习)
11