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

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

ПРЕДИСЛОВИЕ: В нашей организации мы пытаемся использовать Kafka для решения проблемы, которая...

При использовании @KafkaListener можно ли получить ссылку на базовый KafkaConsumer, поскольку я...

Является ли ReplyingKafkaTemplate блокированием?Любая реактивная альтернатива?

У меня есть 2 приложения Spring Cloud Stream «Scs-Processor» и «SCS-Sink», и я использую Kafka для...

Я играю с Кафкой, пытаюсь справиться с этим.Одна из вещей, которую мы должны уметь делать - это...

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

Я использую Kstreams с приложением SpringBoot. Если Kafka закрыт или недоступен, блокируется только...

со следующим @KafkaListener(id = "id1", autoStartup = "false", topics = {...

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

Я использую spring-kafka, и метод, помеченный @KafkaListener, не вызывается, если метод consumer

Я пытаюсь понять соглашение об именовании потоков в Spring Kafka Container Factory при создании...

Используя Apache Kafka 2.1.0 и spring-kafka 2.1.7, мы получаем сообщения об ошибках, подобные...

По умолчанию Kafka отправляет сообщения из темы всем группам потребителей. В моем случае у меня...

Я использую последнюю версию spring-kafka и использую @KafkaListener. Я использую BatchListener. В...

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

Я пишу приложение Spring Boot с помощью Spring Kafka. Поскольку мое приложение ориентировано на...

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

Облачный поток Spring org.springframework.cloud.stream.schema.avro

У меня есть следующий класс автоконфигурации для Кафки: @Configuration @EnableKafka...

Я использую Kafka-client версию 1.0.0 и Spring-cloud-stream версию 2.0.2. теперь я хочу знать...

Я планирую приложение Spring + Kafka Streams, которое обрабатывает входящие сообщения и сохраняет...

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

Я ПИШУ ПОТРЕБИТЕЛЯ КАФКИ Я хочу передать имя темы переменной среды в @kafkalistener (themes = topic...