有没有java读取kafka数据(TiCDC同步到kafka)的例子或文档?

有没有java读取kafka数据(TiCDC同步到kafka)的例子或文档?

我看TiCDC的Open协议中,删除和修改记录时都没有给出记录的老值,那在一些情况下就比较难处理,能否在删除和修改记录时把老的值也给出来?(参考MySQL binlog)

抱歉,有没有java读取kafka数据(TiCDC同步到kafka),这句话我没有太理解。 请问,是要从tidb同步到kafka的例子吗?

是java如何读取TiCDC同步到kafka的数据,有没有这方面的例子~

java 如何消费 kafka 的实践需要用户自己去做,可以到 kafka 社区或者 java 社区看下。

TiCDC在kafka中的格式怎么读取呢?

CDC 没有提供 Kafka 消费端的实现,只提供了开放数据协议,可以依据该协议实现 consumer

那就复杂了…

您好,当前只有go 版本的解析 demo,请参考 https://github.com/pingcap/ticdc/tree/master/kafka_consumer

注意:只是 demo ,不要使用在生产环境,多谢。