У меня проблема с десериализацией сообщений из тем Кафки.Сообщения были сериализованы с...
Наша система состоит из нескольких микросервисов, которые испускают и потребляют события,...
Исключением является ошибка отправки HTTP-запроса в конечную точку:...
Есть кое-что, что я пытаюсь понять о том, как Avro-сериализованные сообщения обрабатываются Kafka и...
Я пишу код Python, который создает схемы в реестре схем. Команда curl для регистрации новой версии...
Я пытался развернуть Kafka с реестром схемы локально, используя Kubernetes. Тем не менее, журналы...
Я определил конфигурацию реестра схем Kafka и Kafka с использованием развертываний и сервисов...
У меня есть соединитель раковины со следующей конфигурацией { "name":...
Я записал некоторые avro-данные в тему «test-avro», используя Kafka-avro-console -roduction. Затем...
У меня есть весеннее приложение, которое является моим производителем кафки, и мне было интересно,...
была одна статья Мартина Клеппмана (в блоге Confluent) о том, что в одну и ту же тему кафки можно...
Насколько я понимаю, схема Avro будет кэшироваться локально, а потребитель будет использовать...
Предыдущее примечание: я довольно новичок в Kafka. Я пытаюсь получить все схемы из реестра схем, но...
Вариант использования Цель состоит в том, чтобы идентифицировать входящие события / строки, чтобы...
У меня есть схема, которая была обновлена, чтобы включить новое поле.Для десериализации /...
Я написал класс Java для извлечения схемы из реестра схем с помощью feignHttp.Вышеуказанное...
Я использую Avro для создания класса.Вот мой код в продюсере выглядит так: TweetInfo tweetInfo =...
Я вижу следующую ошибку exception Unsupported Avro type. Supported types are null, Boolean, Integer...
Я недавно включил двухстороннюю аутентификацию на своем кластере Kafka. Я пытаюсь использовать...
Исходя из моего понимания Производитель: При первом вызове локальный кеш реестра схемы пуст. Затем...
У меня есть кластер kubernetes с тремя узлами в Azure, с тремя брокерами Kafka и одним экземпляром...
Какова обратная сторона обработки разрывающего изменения контракта, которое может отрицательно...
У меня есть часть Java-приложения, которое записывает закодированный AVRO-объект в тему Kafka. Я...
Я оцениваю кинезис как замену кафке. Одна из вещей, которые мне не хватает, - это эквивалентное...
Я настраиваю 3-х узловый кластер Kafka (3 брокера и 3 зоопарка с включенным SSL) с помощью докера