启动ticdc监听时,添加了config参数,用于分发不同topic, 配置中如果没有topic参数,那么正常,如果加了topic则报错, 换成以下写任一写法都报错
[sink]
dispatchers = [
{matcher = [‘!jsk_data.jsk_ads_count*’], topic = “tidb-to-kafka-full”, partition = “ts” },
{matcher = [‘jsk_data.jsk_ads_count_*’], topic = “ads_count_data”, partition = “ts” }
]
[[sink.dispatchers]]
matcher = [‘!jsk_data.jsk_ads_count_*’]
dispatcher = ‘ts’
topic = “tidb-to-kafka-full”
tidb集群版本 v6.1.0
附命令: tiup cdc cli changefeed create --pd=http://192.168.60.4:2379 --sink-uri=“kafka://192.168.60.207:9092/tidb-to-kafka-full?protocol=canal-json&kafka-version=3.2.0&partition-num=4&max-message-bytes=1048588&replication-factor=1&auto-create-topic=false” --changefeed-id=“tidb-to-kafka-full” --sort-engine=“unified” --config /home/sync-tidb-to-kafka.toml