你是不是说反了？ canal 作为 MySQL binlog 增量获取和解析工具，可将变更记录投递到 MQ 系统中，比如 Kafka/RocketMQ，它的上游应该是mysql，做binlog解析的工具。
所谓的canal-json 的协议，只是cdc应用了canal 的解析协议而已，相当于 cdc 解析了tidb 的操作日志，然后以该协议的格式，把内容以json 的格式 传入kafka。
至于你怎么从kafka消费，就取决于你自己了。
你是不是说反了？ canal 作为 MySQL binlog 增量获取和解析工具，可将变更记录投递到 MQ 系统中，比如 Kafka/RocketMQ，它的上游应该是mysql，做binlog解析的工具。
所谓的canal-json 的协议，只是cdc应用了canal 的解析协议而已，相当于 cdc 解析了tidb 的操作日志，然后以该协议的格式，把内容以json 的格式 传入kafka。
至于你怎么从kafka消费，就取决于你自己了。