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

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