TiCDC 能自定义发往 mq 的消息格式吗

现在 TiCDC 支持canal_json等消息格式,可以修改 TiCDC代码自定义消息格式吗?还是要在自己的系统将 canal_json 转成其他的消息格式呀?

建议二次转,直接改ticdc代码对于升级维护会麻烦一点。

下游是什么?要是方便在下游转不是更方便点吗?

好的,直接改ticdc代码的话,是不是还要把修改之后的 ticdc 集成到 tiup里?

下游是 kafka, 目的是想把发往 Kafka的消息格式改一下

tiup 可以设定为本地 mirror,改动后的包放到本地mirror里就可以分发了。
可以参考这段: \https://tidb.net/blog/a0d37d88#再论TiUP组件/tiup%20mirror

好的,非常感谢。

此话题已在最后回复的 60 天后被自动关闭。不再允许新回复。