У меня есть @StreamListener, который принимает строку @Payload.Для тестирования этого класса...

Я провел модульный тест, используя KafkaEmbedded (и KafkaTemplate), но порядок сообщений является...

Мы используем Spring Cloud Stream Kafka Binder (с интеграцией Project Reactor, т.е. Flux потоки ) и...

Я хочу написать модульный тест для Kafka Appender, используя log4j2 xml. Я использую встроенный...

Я использую EmbeddedKafka для тестирования моего модуля со следующей конфигурацией аннотаций:...

У меня есть spring компонент с @KafkaListener методом: @Slf4j @Component public class...

У меня проблема с тем, что мой Kafka ProducerConfig получает недопустимое значение bootstrap

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

Я пишу тестовые примеры Junit (используя @EmbeddedKafka) для моего приложения Spring Boot, которое...

Я пытаюсь сделать интеграционный тест для приложения, использующего kafka, kafka-streams и...

Я использую Kafka и Springboot в своем проекте, теперь у меня есть внешний кластер Kafka и проект...

Я использую EmbeddedKafka для проверки интеграции с Кафкой в ​​моем микросервисе. А также, я...

У меня есть приложение SpringBoot с двумя потоковыми процессорами, сопоставленными через Spring...