Предположим, у меня есть тема под названием "пакетная обработка" с 1 разделом, и я публикую в ней...

Добрый день, коллеги. Я использую Spring Kafka 2.2.5 У меня есть слушатель: @KafkaListener(topics =...

Я делаю проект, используя springboot 2, kafk 2.2.0, spring-kafka 2.2.5 Я создал kafka exactly once...

У меня есть кластерное приложение, построенное вокруг пружинного инструмента, использующего kafka в...

Хочу написать одно новое приложение с загрузкой Spring, используя базу данных как MySQL + Mango и...

Смещение сбрасывается, когда одна тема используется двумя разными группами потребителей. Я...

Я использую зависимость spring-kafka в моем приложении SpringBoot для использования Kafka. Все...

Мое приложение слушает несколько тем.Некоторые из них являются уплотненными темами, используемыми...

Я использую следующие пакеты для приема сообщений kafka compile 'org.springframework

Есть ли простой способ сказать, работает ли потребитель (созданный с помощью весенней загрузки и...

Я создаю новый весенний загрузочный проект с простым тестом: @RunWith(SpringRunner.class)...

Я использую JsonDeserializer для десериализации моего пользовательского объекта, но в моем методе,...

У меня есть следующий класс конфигурации Kafka: @Configuration @AllArgsConstructor(access =...

В связи с: этот вопрос Я пытаюсь прочитать компактную тему через @KafkaListener.Я бы хотел, чтобы...

У меня есть вариант использования, когда потребитель должен использовать минимум n записей, чтобы...

Я пытаюсь настроить кластер kafka на платформе Openshift, используя это руководство:...

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

Я пытаюсь понять, как использовать другой сериализатор / десериализатор ключей в Spring Cloud...

-> Spring Boot версии 1.5.18 и Spring Kafka версии 1.3.8.Я реализовал менеджер разрезов Kafka,...

Я использую spring kafka и хотел бы, чтобы в yaml приложения были указаны несколько групповых...

Spring-kafka потребитель перестает потреблять сообщения через некоторое время.Остановка происходит...

Мне трудно понять некоторые концепции Kafka в Java Spring Boot.Я хотел бы протестировать...

Я сделал слушатель, который слушает тему Kafka с String в качестве ключей и универсальным...

У меня есть проект весенней загрузки, и я подключился к базовому центру событий kafka. Мне нужно...

Мы реализовали одно приложение для создания сообщений плюс заголовки и отправки их в тему кафки