Я хочу создать таблицу со сложным типом, удаленным из данных avro в той же схеме. Это потому, что...

была одна статья Мартина Клеппмана (в блоге Confluent) о том, что в одну и ту же тему кафки можно...

У нас есть Oracle Source, оттуда нужно получить данные, с ошибкой в ​​формате Avro и Json. Файл...

У меня есть несколько csvs с разными заголовками. некоторые из них имеют 12 столбцов, некоторые 14...

Как правильно создать авро-схему для объекта с массивом строк? Я пытаюсь создать авро-схему для...

Я пытаюсь преобразовать данные таблицы BigTable в родовую запись, используя поток данных. После...

Насколько я понимаю, схема Avro будет кэшироваться локально, а потребитель будет использовать...

Я использую Подготовка данных (DP) Google Cloud Platforms (GCP) для перемещения данных в Big Query...

Сгенерированный образец потока из утилиты ksql-datagen из следующей схемы - { "type":...

У меня есть конвейер лучей, который принимает данные json, анализирует их, а затем записывает их в...

Моя искровая работа - чтение с кафки и расшифровка сообщения.моя искровая работа хорошо работает на...

Я хочу создать файл avro из таблицы mysql. Я в настоящее время использую Пандавро. Но pandavro еще...

Я пытаюсь отправить событие avro на esper с помощью сокетов.Я использую класс EsperIOSocketAdapter,...

Я пытаюсь собрать Kafka Sink Connector, производитель отправляет сообщения в Avro.Как преобразовать...

Я пытался создать запись Avro, которая содержит десятичные данные, но потерпела неудачу с...

Как часть POC, я пытаюсь вставить сообщения Avro с включенным реестром схемы из раздела Kafka...

При использовании Avro в качестве выходного формата преобразователя в задаче hadoop MR, как я могу...

У меня установлен модуль maven, и один класс присутствует в двух модулях с одинаковым именем и...

У меня есть схема, которая была обновлена, чтобы включить новое поле.Для десериализации /...

Я написал класс Java для извлечения схемы из реестра схем с помощью feignHttp.Вышеуказанное...

Я пытаюсь получить значения полей из GenericRecord (Avro 1.8.2) genericRecord.get(index) works but...

Я пытаюсь создать приложение Kafka Streams, которое обрабатывает записи Avro, но я получаю...

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

Я строю конвейер, который читает общие записи Avro.Для прохождения GenericRecord между этапами мне...

Я начинающий пользователь Apache Beam.У меня не было проблем с реализацией логики для моих...