Мы пытаемся найти способ сериализации схемы Thrift в формат Avro. Поток выглядит следующим образом:...

Я ищу подходящий учебник / руководство для java kafka-stream со схемой-реестром. У меня есть Google...

Я пытаюсь настроить производителя kafka с KafkaAvroSerialzer для значения. И я сталкиваюсь с этой...

У меня есть avro сообщение и .avsc файл.Я создал класс Java из файла .avsc.Теперь я хочу...

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

Как написать kafka avro сериализатор и десиализатор (т.е. используя io.confluent.kafka.serializers

Авро схема: { "name": "Entity", "type": "record",...

Microsoft Azure решает, в некоторых случаях, выгружать данные в формате avro. Данные, о которых...

Я использую авро схему из: https://avro.apache.org/docs/current/gettingstartedjava

Мы используем процессор ConvertRecord для преобразования CSV в формат AVRO и сталкиваемся с...

Я пытаюсь вставить данные с помощью коннектора Kafka JDBC Sink, но мне возвращается это исключение....

Попытка использовать Flink для чтения потока Kafka сериализованных данных "avro", например:...

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

У меня есть схема Avro с некоторыми полями, определенными как десятичный логический тип.Из этой...

У меня есть файл схемы avro, и мне нужно создать таблицу в Databricks через pyspark.Мне не нужно...

Управление схемами kafka с помощью avro дает нам гибкость для обратной совместимости, но как нам...

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

В настоящее время я запускаю SQL-запрос для извлечения данных из набора данных Public BigQuery в...

Я использую avro 1.8.2 и простую запись avro idl, как, например, record FooRecord { string...

Я пытаюсь начать работу с http4s и ищу avro-кодировщики, которые кодируют / декодируют объекты в /...

У меня есть SchemaRegistry и KafkaBroker, из которого я беру данные с Avro v1.8.1. Для...

Я хочу использовать схемы apache avro для сериализации и десериализации данных. Я хочу использовать...

Я использую ReflectData для генерации схемы из класса Java. Одно из полей private LocalDate...

Я попытался разделить фрейм данных Spark по столбцу отметки времени update_database_time и записать...

Я хотел бы написать код Java для сравнения двух GenericRecords, сохраненных в памяти, оба с...