cdc 同步到kafka 如何将cdc节点信息也传给kafka

tidb版本:4.0.13
需求:通过ticdc将tikv的变更同步到kafka,希望将tidb的信息(或者是ticdc的信息)也传给kafka,比如tidb集群的ip:port,或者ticdc的ip:port。目的是加以区分这条数据是从哪个tidb集群来的。

不知道4.0.13版本是否支持这个需求,我试了protocol=maxwell,canal,default这几个协议都没能实现这个需求。

据我所知,好像没有这个功能

从数据库直接到kafka的CDC我就见过OGG,不过OGG目前不支持tidb

不支持这个功能

该主题在最后一个回复创建后60天后自动关闭。不再允许新的回复。