TiCDC(TiDB Change Data Capture)是用来捕捉和输出 TiDB/TiKV 集群上数据变更的一个工具。它既可以作为 TiDB 增量数据同步工具,将 TiDB 集群的增量数据同步至下游数据库,也提供开放数据协议,支持把数据发布到第三方系统。
应社区小伙伴的号召,TiCDC 源码解读系列持续进行中,本期是系列第 9 期,将在 3 月23 日(周四)20:00 准时开始。
关于本期内容有任何想要了解的问题,也欢迎在本帖留言~将邀请分享嘉宾在直播当天进行解答~👏
直播预约
熟悉 TiCDC 以及想要熟悉 TiCDC 的伙伴们可以扫码快速预约直播:
本期主题
TiCDC 源码解读#9 TiCDC Kafka Sink 实现原理和协议介绍
分享要点
TiCDC 中 Sink 模块拉取 sorter 已排序的行变更,按照特定协议将数据同步到下游。本期主要介绍 Sink 模块中 Kafka sink 的实现原理,会重点关注以下几个问题:
-
Kafka Sink 数据分发原理
-
Arvo 协议介绍
-
canal-json 协议介绍
分享嘉宾
刘东坡 PingCAP TiCDC 研发工程师
分享时间
2023 年 3 月 23 日(周四) 20:00-21:00
扫码即可预约本期直播(预约后,将在直播前收到提示哈~)