У меня есть файл XLS / CSV, который я читаю в панде. Я хочу сгенерировать схему avro из этого...
Мы использовали ValidateRecord для нашего процесса Nifi, чтобы проверить, все ли поля JSON содержат...
Новичок играет с Кафкой и AVRO. Я пытаюсь десериализовать сообщения AVRO в Python 3.7.3, используя...
Я хранил сообщения от разных устройств в формате Azure Blob Storage в формате AVRO. Одно из...
Как преобразовать двоичное Avro в json с помощью схемы avro У меня есть двоичная схема Avro и Avro...
Я пытаюсь создать файл AVRO, используя Go. Пока я попробовал пару библиотек, и у меня есть код....
У меня есть собственный сериализатор avro, но kafka выдает эту ошибку: Ошибка десериализации...
Я использую Spark 2.4.4, import os os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages...
Я изучаю схему реестра, используя слияние. Кажется, я не могу загрузить 'kafka avro serializer'. Я...
У меня есть приложение весенней загрузки. Я также использую org.apache.avro. У меня есть конечная...
Мне кажется, я следую правильной документации , чтобы заставить pyspark записывать файлы avro. Я...
Я не могу создать данные для конкретной схемы и не могу понять, почему. Данные примера, включенные...
Я ищу ту же информацию о том, как подключить конверсию. В настоящее время преобразование всегда...
Я пытаюсь преобразовать файл потока NiFi, содержащий JSON, в запись AVRO. У меня проблема в том,...
Я хочу отправить сообщение Kafka с полезной нагрузкой класса, который расширяется...
Я пытаюсь отправить сообщение JSON в тему Kafka, используя службу Kafka-rest для сериализации JSON...
У меня есть строка в двоичном формате Avro. Я хочу преобразовать строку в JSON. Может ли кто-нибудь...
Я знаю, что уже есть некоторые темы, касающиеся вышеупомянутой ошибки, но я все еще имею ее,...
Я пытаюсь найти некоторую информацию о производительности и (или) преимуществах использования двух...
Мы перемещаем записи json из раздела nifi в раздел kakfa, используя реестр схем. Схема:...
Я очень новичок в мире Кафки и Авро. Я хотел бы использовать Avro + Schema Registry для Kafka. Тем...
Я пытаюсь использовать классы модели предметной области, сгенерированные из схемы с использованием...
Для целей миграции нам нужно создать записи, используя два разных сериализатора и, следовательно,...
Я поместил свои данные в mysql, но сейчас пытаюсь поместить их в улей. Я не мог найти нужные...
Извините, если это уже описано в документации Кафки или в руководстве, и я был бы благодарен, если...