如果要自定义 sink 的话需要实现 https://github.com/pingcap/tiflow/blob/master/cdc/sinkv2/eventsink/event_sink.go 和 https://github.com/pingcap/tiflow/blob/master/cdc/sinkv2/ddlsink/ddl_sink.go 里面的接口，可以参考 https://github.com/pingcap/tiflow/tree/master/cdc/sinkv2/eventsink 跟 https://github.com/pingcap/tiflow/tree/master/cdc/sinkv2/ddlsink 这两个目录下其他 sink 的一些实现，如 mq (Kafka)、txn (MySQL/TiDB) 和 cloudstorage (S3/NFS)