方案1（推荐）：提前建好 topic
./kafka-topics.sh --create
–bootstrap-server xxx:9092
–topic topic_ticdc_saleslink_uc_employee_emp_employee
–partitions 3
–replication-factor 3
优点：
- 完全可控
- 最稳定
- 生产推荐
方案2：关闭 Kafka 自动创建 topic
在 Kafka 配置中：
auto.create.topics.enable=false
然后：
- TiCDC 写入失败（因为 topic 不存在）
- 强制你必须提前创建
方案3：修改 Kafka 默认分区数
num.partitions=3
缺点：
- 影响所有新 topic（不推荐生产）