У меня есть служба сокетов, которая отправляет сообщения в формате JSON.Типичное сообщение выглядит...

Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for...

Я пытаюсь создать универсальный AvroSerde в Scala.Я буду использовать этот serde в сочетании с...

Я пытаюсь прочитать сообщение от Kafka, используя потребителя со следующими свойствами value

Как схемы из Confluent Schema-Registry распространяются Confluent-Replicator по назначению...

Я пытаюсь отправить данные через поток Kinesis в формате Avro.Но я столкнулся с проблемой -...

Простой пример иллюстрирует мою проблему. По сути, я работаю над большим проектом, в котором код...

Я видел некоторую противоречивую информацию о том, способен ли Sqoop обрабатывать следующий...

У меня есть несколько тем, подобных этой client1-table1 client1-table2 client1-table3...

У меня есть входящие записи Avro, которые примерно соответствуют формату ниже.Я могу читать их и...

Я использую NiFi Flow в качестве ListFile >> FetchFile >> SplitJson >> UpdateAttribute >>...

STREAM-1: [KSTREAM-SOURCE-0000000000]: null, {"id": 1, "name": "john"...

Учитывая, что файлы Avro и Parquet содержат и данные, и схему для этих данных, то в Spark должна...

Поток NiFi для чтения файла json, выведите схему авро, объедините содержимое и сохраните как паркет...

Я хочу сделать три вещи Проверить JSON по JSON-схеме Создать JSON-схему в AVRO Преобразователь...

Я использую Zeppelin , чтобы читать файлы avro размером в ГБ и иметь записи в миллиардах.Я пробовал...

У меня есть файл, содержащий данные в формате AVRO, которые необходимо опубликовать непосредственно...

Я создаю приложение для электронной коммерции, в котором в настоящее время я работаю с двумя...

Я хотел бы иметь схему avro, которая имеет поле с именем validExtensions. Как я могу сделать...

Я пытаюсь построить конвейер kakfa, который будет считывать входные данные JSON в тему Kafka. Я...

У меня есть пример схемы Avro: { "type": "record", "name":...

У меня есть следующая конфигурация для моего приложения Kafka Stream Properties config = new...

Я работаю со Scala и Avro и в один момент - тип переменной: import scala.reflect.runtime.universe._...

Я новичок в Avro и уже знаю, что это фантастическая библиотека, я хотел бы помочь мне приспособить...

Я новичок в Avro.Я пытаюсь проанализировать простой CSV-файл, содержащий одно строковое значение и...