cdc 是直接到 kafka 阿,但是从kafka 接收数据的时候,就需要自行处理。
ticdc 标准的协议有样例
https://github.com/pingcap/tiflow/tree/master/examples/java
https://github.com/pingcap/tiflow/tree/master/cmd/kafka-consumer
cdc 是直接到 kafka 阿,但是从kafka 接收数据的时候,就需要自行处理。
ticdc 标准的协议有样例
https://github.com/pingcap/tiflow/tree/master/examples/java
https://github.com/pingcap/tiflow/tree/master/cmd/kafka-consumer