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

У меня есть проект Spring Kafka, и я написал для него несколько модульных тестов. Когда я выполняю...

Я прочитал документацию по spring-kafka, примеры, которые я нашел, и половину стека overoverflow,...

Я следил за этим сообщением в блоге, чтобы реализовать встроенный sasl_ssl https://sharebigdata

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

Я использую spring-boot-starter-parent версию 1.5.0.RELEASE, spring-kafka версию 1.0.0.RELEASE и...

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

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

В моем проекте Spring Boot, где у меня есть несколько потребителей Spring Kafka, я добавил...

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

Я отправляю сообщение в Kafka с помощью ReplyingKafkaTemplate, и оно отправляет сообщение с...

У меня есть простое приложение Spring Boot, которое читает из Kafka и пишет в Kafka. Я написал...

Я использую Spring Kafka с аннотацией @EmbeddedKafka для запуска экземпляра Embedded kafka....

@ EmbeddedKafka выводит кучу ошибок при завершении работы.Есть ли способ предотвратить это?Трудно...

Моя тестовая зависимость связана с kafka, как показано ниже: | +--- org.apache.kafka:kafka_2.11:2.0

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

Я пишу интеграционный тест с использованием spring-kaka-2.2.0 в приложении весенней загрузки, мне...

Я пытаюсь провести интеграционное тестирование с использованием spring-boot и встроенного в пружину...

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

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

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

В настоящее время я использую spring boot 2 и junit 5. Я хочу использовать spring-kafka-test для...

При использовании Integer в качестве ключа это не проблема, kafka должен иметь возможность...

Это проводной, только что запущенный проект весенней загрузки с простым основным классом, он...