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