topic是提前手动创建的:
kafka-topics.sh --create --zookeeper XXX --replication-factor 3 --partitions 3 --topic test1
sink-uri是这样的:
/usr/bin/cdc cli changefeed create --pd=XXX --start-ts=XXX --sink-uri="kafka://XXX/test1?message.max.bytes=2147483648?partition-num=3