У меня есть проект, настроенный таким образом: spring: cloud: stream: rabbit: bindings: myChannel:...

Я только что обновил весеннюю загрузку до 2.1.0.RELEASE и весенний облачный поток до Greenwich.SR1....

Мы только что обновили нашу Spring до: Spring boot: 2.1.0.RELEASE Spring cloud: Greenwich.SR1...

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

Я использую Spring Cloud с Apache Kafka. Сообщения, отправляемые в тему кафки, обычно также...

Я пытаюсь протестировать приложение с настроенной следующей привязкой: spring: cloud: stream:...

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

Предположим, у меня есть тема Kafka с именем account с несколькими типами сообщений (каждый со...

После прочтения этой статьи я смог прочитать из одной темы1 и опубликовать в другой теме2. Но когда...

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

У меня есть Spring Cloud Stream, материализованный в GlobalKTable. Для локальной среды разработки...

Я использую spring-cloud-stream-kafka и не понимаю, как можно изменить свойство key.serializer при...

У меня есть приложение Spring Cloud Kafka Streams, которое использует StateStore в Processor API...

Собственный API Kafka позволяет создавать и добавлять хранилище состояний с помощью StreamsBuilder...

Я использую spring-cloud-stream-kafka, версия 2.1.2.И повторите попытку, используя RetryTemplate по...

Я пытаюсь интегрировать кинесис Spring Cloud Stream в мое приложение, но я не могу найти все опции...

Я собрал потребителя пружинной загрузки Kinesis со следующими компонентами: пружинный башмак...

В методе процесса @StreamListener я сопоставляю школу KStream с персоной KStream и с помощью метода...

Обычный способ реализации шаблона исходящих сообщений состоит в том, чтобы сохранить полезную...

У меня есть потоковая служба Spring Cloud SSE #webflux, и мой фронт подключается к ней через Nginx

Я пытаюсь выполнить внутреннее соединение между KStream-KStream.Я заметил, что объединение не...

Я создаю набор микросервисов в среде Spring Boot, каждый из которых интегрируется с Kafka для...

После прослушивания темы kafka с использованием @StreamListener, при RuntimeException, глобальном...

Я использую spring-cloud-stream: 2.1.1.RELEASE с привязкой Rabbit. Имена очереди, сгенерированные...

Сейчас я пытаюсь создать функцию службы сообщений с помощью kafka для использования...