有知道5.0的ticdc的cdc/sink/cdclog包变成了6.0的tiflow就到哪里去了吗

[TiDBer_8xv3YpMO]

[xinyuzhao]

6.0 中 cdc change log 保存到文件这个功能暂时被去掉了，现在在 6.5 重新加以完善，具体代码可参考 storage sink， 文档可参考storage sink 文档

[TiDBer_8xv3YpMO]

好的谢谢。tiflow现在支持自定义下游吗

[TiDBer_8xv3YpMO]

如果我想要自定义sink下游得去哪个文件做修改呢

[xinyuzhao]

如果要自定义 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)