我有一个要求,即传入Kafka的消息(使用Source连接器)是以XML的形式 . 这里有2个问题 .

  • 是否可以配置源/接收器连接器以保留消息的XML格式?

  • 其次,有没有办法在将XML存储到主题之前将其转换为JSON . 我已经读过单个消息转换(SMT)可以在源连接器上用于转换,但是找不到具体的处理XML到JSON转换的东西 .

提前致谢 .