Spark 2.4.0 на Java 1.8.0_161 (Scala 2.11.12) Команда запуска: spark-shell --jars=spark-avro_2.11-2

Я создал таблицу в avro serde в Hive, используя нижеприведенную команду создания CREATE EXTERNAL...

Я пытаюсь использовать пакет spark-avro, как описано в Руководство по источникам данных Apache Avro...

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

Я последовал примеру записи файла AVRO в Документация по Beam . Но это дает мне ошибку Caused by:...

Я хотел бы протестировать Spring Cloud Stream с регистрацией Confluent Schema и эволюцией Avro...

Я пытаюсь загрузить несколько файлов AVRO в большой запрос, следуя этой документации: https://cloud

Я создал схему Avro для записей, которые мы публикуем в нашей теме Kafka.Наша фактическая схема...

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

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

Моя цель - у меня есть приложение для загрузки весенних приложений kafka со свойством сериализации...

Я читаю данные с машины и транслирую их как JSON в тему кафки. Я хотел бы прочитать эту тему и...

Примеры приложений для проверки этого можно найти в https://github

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

Моя конфигурация: Confluent (5.0.0) Kafka выдает несколько авро-сообщений. Рабочий Connect...

У меня есть тема, в которой будет много разных схем. На данный момент это только один. Я создал...

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

Кто-нибудь сталкивался с этой ошибкой? io.confluent.kafka.schemaregistry.client.rest.exceptions

Я создал классы POJO для генерации схемы Avro, но не заметил, что первое определение типа Календаря...

Я пытаюсь преобразовать xml-файл в avro, а затем в паркетный формат без использования инструментов...

Я использую схему Avro для записи данных в тему Кафки.Изначально все работало нормально.После...

В первый момент мне пришлось обработать информацию из текстового файла: C1-4-, C2_4, С1 ______ 10...

Предположим, что приложение Spring Cloud Stream создает KStream из order topic.Интересует...

У меня много микросервисов для чтения / записи сообщений Avro в Кафке. Схемы отличные. Авро отлично

Мы планируем удалить версии из названий тем kafka.В настоящее время версия схемы соответствующего...