Я пытаюсь опубликовать авро-сообщение, используя AvroProducer confluent-kafka-python, используя...

У меня есть несколько тем kafka с форматом avro, я создал поток и таблицу, чтобы можно было...

Работа над проектом с использованием клиента .net confluent kafka, получение исключения при...

Я получил сообщение об ошибке «Объект типа mappingproxy не поддерживает сериализацию JSON» при...

У меня есть две схемы: DataRecord.avsc: { "namespace": "com.mycompany",...

Я установил платформу слияния на AWS. Мой источник - MySql, и я подключил его к Kafka connect с...

Я ищу какой-нибудь пакет python, который помог бы мне легко генерировать случайные данные XML и...

Я использую spark и scala и пытаюсь читать папки avro с помощью com.databricks - spark-avro_2.11

Я учусь сериализовать данные с помощью avro. Я хотел бы сериализовать больший набор данных. Может...

Я создаю микросервисную часть программного обеспечения с использованием API-подхода, я хотел бы...

Я пытаюсь десериализовать сообщение kafka в формате avro. Я использую следующий код: https://github

Моя настройка следующая: я извлекаю XML-файлы с ftp-сервера, распаковываю их в POJO, сопоставляю их...

Я сгенерировал свои классы Avro Java из схемы Avro с помощью avro-maven-plugin. Я сериализую свой...

У меня есть существующая схема avro, которая содержит поле с вложенной картой карты типа записи (на...

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

У меня задание Kafka-Connect, настроенное на периодический запрос таблицы MySQL и размещение...

Я использовал Ruby gem avro_turf, чтобы преобразовать данные в двоичные файлы и опубликовать их в...

Я знаю, что Avro поддерживает Map [String, String]: { "name": "my_avro_field",...

Я изменил apache-beam SDK с 2.5.0 на 2.12.0 и получил ошибку схемы Avro при чтении таблицы из Big...

Я сохранил данные в формате Avro (Generic Record) в Kafka и затем извлек их. Данные состоят из 2...

У меня есть две схемы, скажем, A и B. B зависит от A. Например, A является { "namespace":...

Мы создаем конвейер потока данных, мы будем читать данные из postgres и записывать их в файл...

У меня есть набор микросервисов, взаимодействующих через события на Кафке. Иногда случается, что у...

Редактировать: я обнаружил этот другой вопрос несколько лет назад ( Как заполнить кэш в...

Мне интересно, как добавить свойства к AvroProducer в python. Вот код, который я пробовал, вы...