TICDC创建过滤规则不生效

【 TiDB 使用环境】测试/
【 TiDB 版本】8.5
【复现路径】做过哪些操作出现的问题
【遇到的问题:问题现象及影响】根据官网提供API创建TIDB-CDC同步到Kafka的同步任务,
https://docs.pingcap.com/zh/tidb/stable/ticdc-open-api-v2#创建同步任务
过滤和分发器不生效
请求体:


返回结果:


我在请求体中过滤了test库下面的test_stu 并且设置了 分区分发规则,但是返回的值并没有过滤信息和分发信息。配置的过滤条件貌似没有生效? 是我请求体哪里写的不对吗?

你 create changefeed 时 changefeed.toml 是怎么写的?

如果我没有记错的话,应该 ticdc 不支持过滤同步

我是用HTTP请求 TICDC的API创建的, 没有用toml文件。

https://docs.pingcap.com/zh/tidb/stable/ticdc-open-api-v2#创建同步任务
可是我看到官网的提供的API页面是有filter参数的呀

格式不正确,filter 应该放在 replica_config 里面。https://github.com/pingcap/tiflow/blob/e19c522988e45ca2a10e5c2bf39e8522fa1dcfa7/tests/integration_tests/api_v2/cases.go#L293

2 个赞

感谢您的回答,放在replica_config 中后过滤生效了,但是分发规则我想通过每个表的主键id发到对应的分区应该怎么写呢, 这是我最新的请求和返回。
请求:

返回:

参考:
https://docs.pingcap.com/zh/tidb/stable/ticdc-sink-to-kafka#partition-分发器

partition = “index-value”

1 个赞

感谢回答,我刚才试了,是可以的。

1 个赞

此话题已在最后回复的 7 天后被自动关闭。不再允许新回复。