У нас есть таблица kTable, в которой мы отображаем значения и материализуем их в KeyValueStore,...
У меня есть вопрос о SpecificAvroDeserializer, поскольку из-за имени класса я всегда предполагал,...
Как использовать стандартный инструмент kafka-avro-console-consumer с Kafka, работающим через...
Я пытаюсь понять Avro Serialization на Confluent Kafka вместе с использованием реестра Schema.До...
Я работаю над confluent-4.1.1 с помощью ksql cli.Могу ли я создать поток для вложенного формата...
Я хочу запустить схему реестра в ведомом режиме в Kubernetes, я передал переменную окружения master
У меня есть файл, в котором двоичный файл avro добавлен рядом друг с другом.Я хотел бы прочитать...
У меня есть конкретный класс, который я сериализирую в байтовом массиве для отправки в тему Кафки
Я пытаюсь прочитать данные из DB2, используя Kafka, а затем записать их в HDFS.Я использую...
Я пытался подключиться с kafka-avro-console-consumer от Confluent к нашему устаревшему кластеру...
При создании данных AVRO для Kafka, сериализатор Avro записывает тот же идентификатор схемы в...
Я зарегистрировал схему в разделе «Физика» в реестре schmema. curl -X POST \...
У меня есть текст в одну строку в формате JSON:...
у нас очень странное поведение с приложением, которое использует kafka avro для потребителя и...
Я вижу ошибку в моих журналах, что Subject с именем A.Abc-key отсутствует. Я перечислил все...
Как я могу остановить преобразование числа в формат байтов при загрузке таблицы Oracle в Kafka с...
Есть ли способ создать схему из карты. У меня есть карта с парами ключ-значение, и я хочу создать...
Я определил схему в реестре схем с 10 полями. Использование confluent-3.3.0 , Кафка 0.10...
Я попробовал официальный пример schema-registry-confluent (потребитель / производитель) с моим...
Я развернул 3 модуля реестра схемы в кластере k8s. Я пытаюсь выяснить, какой модуль реестра схемы в...
У меня есть Kafka Producer, который отправляет записи Avro в «тестовую» тему. У меня также есть...
Можно ли использовать avro DataFileWriter с реестром схемы?
Мы используем Kafka, Avro и Avro Schema Registry.Учитывая набор тем, которые я хочу использовать,...
Я пытаюсь интегрировать Avro и Schema Registry в наши конвейеры данных Kafka.Теперь он выглядит...
Caused by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro schema for...