Ребят, такой вопрос: Есть следующая конфигурация: Kafka -> Kafka Connect

Question

Ребят, такой вопрос: Есть следующая конфигурация: Kafka -> Kafka Connect

Elasticsearch Connector -> Elasticsearch
Кафка и коннектор развернуты на конфлюентовской платформе.
На вход в топик кафке прилетает JSON. Одно из полей этого JSON'а содержит строку в формате hex.
Существует ли способ конвертировать эту строку в ascii посредством коннекторов/конверторов для конфлюентовской платформы?
Самое близкое, что удалось найти, это connect-transformations и kafka-connect-common-transformations, но в них необходимый функционал не обнаружил.

#kafka #russian #software

0

28.03.2019

3 ответов

5 просмотров

Kirill B

Не уверен, но может быть с помощью KSQL можно произвести это преобразование и кидать данные в новый topic, который уже консьюмить elasticsearch-connector'ом? Но это конечно так себе решение, т.к. дублицирование данных и все такое....

0

28.03.2019

Oleg

можно свой кастомный класс трансформации сделать и подложить в classpath

0

30.03.2019

Anton Korotkikh · Accepted Answer

Anton Korotkikh

зачем ascii в 2к19?

0

28.03.2019

52 похожих чатов

Ребят, такой вопрос: Есть следующая конфигурация: Kafka -> Kafka Connect

3 ответов

Похожие вопросы