TICDC到kafka报错

大概知道了,好像是分发规则这块做的不对
[sink]
dispatchers = [
{matcher = [‘tidb_example.*’], topic = “{schema}_{table}”, partition = “index-value” }
]
这么写试下

可以看下这个

1 个赞