CDC同步到kafka 分发器使用问题

partition = “xxx” 加上试试看?