avro

2зной

1ответ

Kafka Avro Сериализатор: org.apache.avro.AvroRuntimeException: не открыт

Я использую Apache Kafka с Avro Serializer, используя определенный формат. Я пытаюсь создать свой собственный пользовательский класс и использовать его как значение сообщения kafka. Но когда я пытаюсь

1зной

2ответ

Apache Kafka Avro Deserialization: невозможно десериализовать или декодировать сообщение определенного типа.

Я пытаюсь использовать Avro Serialize с Apache kafka для сериализации/десериализации сообщений. Я создаю один продюсер, который используется для сериализации сообщения определенного типа и отправки ег

2зной

1ответ

Получение недопустимого начального символа: в разборке схемы

Я использую Avro 1.8.1 и пытаюсь проанализировать следующую схему_2. Не могли бы вы помочь? val schema: Schema = new Schema.Parser().parse(StrSchema) I am getting following exception. Exception in

0зной

1ответ

Какой производитель собирает и конвертирует журналы веб-сервера в формат avro и пишет в kafka?

В настоящее время я хочу собрать журналы веб-сервера apache (файлы access_logs, error_logs) и написать в Kafka в формате Avro. Доступен ли существующий производитель для этой операции ?. Если вы не мо

0зной

1ответ

Максимальный размер Предел в avro

Как можно задать ограничение максимального размера/длины для типа данных в генерации Avro Schema. Например: В схеме я хочу указать поле, которое принимает строку max len 25.