KSQL - 将 XML 转换为 JSON/AVRO

【问题标题】：KSQL - Convert XML to JSON/AVROKSQL - 将 XML 转换为 JSON/AVRO
【发布时间】：2020-05-20 12:23:20
【问题描述】：

我有兴趣将数据从 SQL Server 加载到 Kafka 。表中的一列是 XML 列。我们如何在 KSQL 流中将 XML 转换为 JSON 或 AVRO 共振峰？

【问题讨论】：

【解决方案1】：

您可以使用Kafka Connect 和XML Single Message Transform (SMT)。

例如：

transforms=Key
transforms.Key.type=com.github.jcustenborder.kafka.connect.transform.xml.FromXml$Value
# The following values must be configured.
transforms.Key.schema.path = < Configure me >

更多信息可以参考this Github repository。

【讨论】：

谢谢@Giorgos。我正在查看 KSQL 流中的内容。
@RaghavaReddy 您必须先将数据导入 Kafka，然后才能使用 KSQL。 Kafka Connect 将用于做到这一点