Я создал одну тему кафки с одним разделом. kafka-topics --create --topic files.write...

Я получаю эту ошибку ОШИБКА CachingConnectionFactory: 1302 - Отключение канала: ошибка канала;Метод...

Я хочу правильно удалить объект из KTable. У меня есть следующие данные потоковой обработки: input

Как я вижу в новой версии spring-cloud-stream 2.1.0 (spring-cloud greenwich). В классе org

Исключением является ошибка отправки HTTP-запроса в конечную точку:...

Обработчики на основе Reactor spring-cloud-stream обеспечивают аккуратный интерфейс для реактивного...

Я использую Spring Cloud Stream версии 2.1.0. RELEASE для отправки сообщений (в данном случае в...

Я переносу проект, использующий Spring AMQP, в проект, использующий Spring Cloud Stream с RabbitMQ....

Я создаю приложение Kafka, используя сжатие журналов по теме, но не могу отправить значение...

У меня есть проект Springboot + Spring Cloud Streams, там у меня настроено несколько потоковых...

Я использую spring-cloud-stream для получения сообщения от Rabbit MQ. У меня есть очередь и...

Я использую Spring Cloud Stream (Edgware.SR5) с Spring Boot (1.5.10.RELEASE). Мой @StreamListener...

В Spring Cloud Stream вы можете объявить очередь недоставленных писем для привязки «input1» с...

Поскольку Spring Cloud Stream не имеет аннотации для отправки нового сообщения в поток (@SendTo...

У меня проблема и ниже код: - MainService.java public void someMethod(Message message){ A aObj =...

Мы запускаем весеннее облачное приложение, использующее spring-cloud-kafka-streams. Приложение...

Я использую Spring Cloud Stream с Spring Boot. Мое приложение очень простое: ExampleService.class:...

Я пытаюсь создать тесты для моего проекта spring-cloud-stream. Я создал свой собственный интерфейс...

У меня есть приложение весенних облачных потоков с потоковым приемником, потребляющим события из...

Я использую Reactive Spring Cloud Stream, и у меня возникают проблемы при создании StreamListener...

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

Он работал нормально, внезапно это всплывающее окно проблемы с 18 декабря, не мог найти никакой...

Описание проблемы: Наш потребитель Kafka (разработанный в Spring Boot 2.x) работает в течение...

Производитель exchange name : xyz, exchange type: direct, queue: myqueue, routingkey : myroutingkey...

Моя цель - создать синхронный процесс, который может вызываться конечной точкой REST.В моей...