У меня проблемы с использованием данного смещения с использованием python, в Java я реализовал...

Настройка выглядит следующим образом.Мы используем kafka, zookeeper, kafdrop и схему-реестр, а...

Проверяя Google Protobuf any.proto (https://github

Начиная с Spark 2.4.0, можно сохранять как AVRO без внешних банок.Однако я не могу заставить его...

Какова лучшая практика для совместного использования схемы Avro / сгенерированных источников? У...

Я использую Кафку с сообщениями Avro.Одно из моих полей определено так: { "name":...

Я создал источник и коннектор приемника для kafka connect Confluent 5.0, чтобы отправить две...

Мне нужно рассчитать среднее с потоками кафки.Продюсер производит с Avro, поэтому мне нужно...

Итак, у меня есть запись avro, например (назовите ее v1): record MyRecord { array<string>...

У меня есть следующий код для преобразования объекта в Json: public static Function<Object,...

При генерации Java-кода из схемы Avro с помощью коммерческого модуля Gradle, он берет объект,...

Я использую следующий инструмент <dependency> <groupId>tech.allegro.schema

Для этого нужно создать схему Avro -> {"city":"XXXXXX",...

У меня проблема с десериализацией сообщений, опубликованных в теме Кафки. Я использую Spring-boot,...

Какова обратная сторона обработки разрывающего изменения контракта, которое может отрицательно...

У меня есть таблица Hive, в которой есть столбец типа данных struct (пример ниже).Таблица создана в...

Мы планируем выгрузить события с Kafka на S3 (например, с помощью kafka connect). Цель состоит в...

У меня есть файл Avro, содержащий десятичный логический тип, как показано ниже:...

Я использую AvroIO.<MyCustomType>writeCustomTypeToGenericRecords() для записи общих записей в...

У меня есть часть Java-приложения, которое записывает закодированный AVRO-объект в тему Kafka. Я...

Из того, что я могу сказать, с помощью десериализации Flink AVRO вы можете создать поток...

Я оцениваю кинезис как замену кафке. Одна из вещей, которые мне не хватает, - это эквивалентное...

Я работаю над получением данных из исходной БД в HDFS в формате avro. используя пакет spark-avro,...

У меня есть автоматически сгенерированная схема avro, которую я могу кодировать и декодировать в...

Я использую Confluent KafkaAvroDerserializer для десериализации объектов Avro, отправленных через...