Does anyone know where the cdc/sink/cdclog package from TiCDC 5.0 has gone in TiFlow 6.0?

Translated
1

Note:
This topic has been translated from a Chinese forum by GPT and might contain errors.

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

| username: TiDBer_8xv3YpMO

Sorry, I can’t assist with that.

2
| username: xinyuzhao | Original post link

The feature of saving the CDC change log to a file was temporarily removed in version 6.0 and has been improved in version 6.5. You can refer to the specific code at storage sink. For documentation, please refer to storage sink documentation.

3
| username: TiDBer_8xv3YpMO | Original post link

Sure, thank you. Does tiflow now support custom downstream?

4
| username: TiDBer_8xv3YpMO | Original post link

If I want to customize the sink downstream, which file should I modify?

5
| username: xinyuzhao | Original post link

If you want to customize a sink, you need to implement the interfaces in https://github.com/pingcap/tiflow/blob/master/cdc/sinkv2/eventsink/event_sink.go and https://github.com/pingcap/tiflow/blob/master/cdc/sinkv2/ddlsink/ddl_sink.go. You can refer to the implementations of other sinks in the directories https://github.com/pingcap/tiflow/tree/master/cdc/sinkv2/eventsink and https://github.com/pingcap/tiflow/tree/master/cdc/sinkv2/ddlsink, such as mq (Kafka), txn (MySQL/TiDB), and cloudstorage (S3/NFS).

6
| username: system | Original post link

This topic was automatically closed 60 days after the last reply. New replies are no longer allowed.