У меня есть 10 тем, и я отправляю 1000 сообщений брокеру каждые 5 минут, и я потерял несколько...

Я использую Spring Kafka 2.2.7, я настроил @EnableKafka с kafkaListenerContainerFactory и использую...

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

Эй, я следовал пошаговому руководству по настройке kafka при весенней загрузке. Но теперь я не могу...

В моем проекте springBoot я использую kafka прослушивающее сообщение, например:...

У меня есть простой проект Spring Cloud Stream, использующий потоки Spring Integration DSL и...

В нашем приложении мы используем потребителя kafka для определения отправки электронной почты. На...

Я создал тему Кафки с тремя разделами. Используя ProducerFactory в Spring-Kafka, я могу создать...

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

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

У нас есть Kafka Consumer (параллелизм 5) с ручным подтверждением. В приведенной ниже реализации...

При подтверждении вручную kafka, при использовании / обработке огромного количества сообщений, мы...

Я хотел бы написать интеграционный тест для всего потока kafka. В моем производственном коде у меня...

У меня есть приложение Kerberized с пружинной загрузкой, которое соединяет Кафку, и Кафка не...

Я хотел бы разделить свой входной поток на два потока, например KStream<String, TypeA> и...

Когда использовать ExponentialBackOffPolicy против FixedBackOffPolicy при установке политики...

В настоящее время у меня есть такой код: KafkaTemplate<String, String> kafkaTemplate;...

Описание проблемы: Я создаю весеннее облачное приложение Kafka stream. У меня есть одна входная...

У меня есть требование отправить запрос и ответ моего микросервиса брокеру Kafka. Я могу сделать...

Как подключиться к нескольким серверам начальной загрузки (DEV, STAGE и PROD) из микросервиса...

У меня есть тема, которая имеет коэффициент репликации и разделения 3. В настоящее время имеется...

Есть ли какая-либо полностью готовая к работе поддержка Kafka в экосистеме Spring Boot? Под...

Exception Stacktrace: org.springframework.kafka.core.KafkaProducerException: Failed to send; nested...

Я хотел бы запустить свои интеграционные тесты, но я не знаю, как отключить @EnableKafka. Мое...

Нам нужно использовать данные из определенной темы в определенное время в течение дня, мы хотим,...