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