Можно ли использовать преобразователь значений Kafka connect (JSONConverter) для преобразования GPB?

Question

Может ли преобразователь значений Kafka connect (JSONConverter) использоваться для преобразования GPB?

Я использую kafka connect в качестве приемника и записываю все тематические сообщения (GPB) в базу данных

Я использую JSONConverter по умолчанию в качестве valueconverter в поле value.converter в файле свойств, это можно использовать для преобразования объекта GPB?

Если нет, могу ли я использовать класс десериализатора, используемый для десериализации этого объекта, или мне нужно написать какой-нибудь другой пользовательский класс? не могли бы вы поделиться примером того же

Answer 1

Нет, JSONConverter ожидает строго отформатированный JSON. Протоколные буферы (я полагаю, это то, что вы имеете в виду под GPB?) Являются двоичными записями и нуждаются в соответствующем преобразователе.

К счастью, у сообщества есть один доступный здесь: https://github.com/blueapron/kafka-connect-protobuf-converter/blob/master/README.md