K SQL - конвертировать XML в JSON / AVRO - PullRequest
1 голос
/ 04 февраля 2020

Меня интересует загрузка данных с SQL Сервера на Кафку. Один из столбцов в таблице XML один. Как мы можем преобразовать XML в JSON или AVRO в K SQL потоках?

1 Ответ

0 голосов
/ 04 февраля 2020

Можно использовать Kafka Connect и XML Преобразование одного сообщения (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 >

Для получения дополнительной информации вы можете обратиться к этому репозиторию Github .

...