Структурированные данные, полученные из темы Кафки

Question

Я получил некоторые данные из топики кафки c. Я использовал эту конфигурацию в файле yml

ключ-десериализатор: org. apache .kafka.common.serialization.StringDeserializer

значение-десериализатор: org. apache .kafka.common.serialization.StringDeserializer

Данные, которые я получил в консоли:

? 8Enterprise, рекомендованный A C

Это Avro Data ?? И если это так .. Что я должен сделать, чтобы преобразовать его в Json данных. Нужно ли конвертировать или десериализовать ??

Answer 1

зависит от способа составления сообщения перед его записью в топи c. Если вы десериализовали с помощью String Deserializar, и ваш вывод кажется правильным, возможно, вы также использовали String Serializer для записи значения сообщения в топи c.

Это не Avro или структурированные данные. Вы можете использовать json или Avro для сериализации данных при создании сообщения, а затем использовать тот же десериализатор при использовании сообщений для получения сообщения с данными структуры.

Если вы скажете мне, что ваш язык программирования может быть могу привести пример.

Надеюсь, это поможет