现在的MySQL中有很多是在触发器中作额外的处理，TiDB中推荐用CDC，那么Java程序能够读取CDC的数据吗？有没有相关文档？
1 个赞
你好，目前需要接 kafka，java 从 kafka 里面读。
这里有如何设置一个 kafka sink 的文档：
https://pingcap.com/docs-cn/stable/ticdc/manage-ticdc/#管理同步任务-changefeed
这里是写入 kafka 的数据格式：
https://pingcap.com/docs-cn/stable/ticdc/ticdc-open-protocol/
1 个赞
TiDB的binlog跟MySQL是兼容的吗？以前我们是通过canal去读取MySQL的binlog，有没有可能让canal去读取TiDB的binlog？
我也在这个贴上补充问下CDC能像canal 库表过滤以及kafka 上多topic 对应吗？
有java读取kafka中的TiDB CDC数据的例子吗？
1 个赞
另外，当记录被删除或修改时原记录所有字段的值会通过CDC输出吗？
此话题已在最后回复的 1 分钟后被自动关闭。不再允许新回复。