Я описал входы и выходы public interface UserStream { String USER_CREATE_EVENT_OUTPUT =...

У меня есть работник Spring-Cloud-Stream, который использует привязки kafka @Slf4j...

Каждое утро, когда я запускаю свое приложение на основе Spring-Cloud-Stream и...

У меня есть производитель, скажем, Приложение A со следующей конфигурацией, Свойства производителя:...

У меня проблема с агрегацией KStreams и окнами. Я хочу объединить запись в список записей, которые...

У меня возникла странная проблема с приложениями Spring Cloud Stream после обновления до Spring...

Я видел похожий вопрос здесь , но он для более старой версии.Не уверен, что для меня конфликтующая...

я использовал spring-cloud-starter-stream-kafka 2.1.2 Потребители для соответствующей темы были...

Как издатель я опубликую сообщение в google pubsub проекта 1 (учетные данные 1) Как подписчик, я...

Я использую связыватель Spring Cloud Stream Kafka, выпуск Edgware.SR4. Я установил настраиваемые...

У меня есть производитель коннекторов kafka-connect jdbc, который публикует сообщение в теме А. Я...

После обновления до весеннего облачного потока 2.1 в проекте, использующем multi binder kafka (2...

У меня есть приложение Spring Boot с аннотированным методом ServiceActivator для чтения объектов...

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

Я создал приложение весенней загрузки для публикации сообщения в очереди Kafka.Для этого я...

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

Я использую последний Greenwich.SR1, который включает Spring-Cloud-Stream (версия: Fishtown.SR2) и...

Сейчас я пытаюсь получить доступ к описателю основных потоков kafka, выполнив - https://cloud

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

Я пытаюсь создать оконное хранилище из набора точек данных, но похоже, что ветвь топологии потока...

Ссылаясь на это решение , файл My spring-cloud-stream application.yml имеет следующую конфигурацию:...

Согласно документации в Spring Aws Kinesis Binder, значения по умолчанию для readCapacity и...

Я пишу приложение Spring Boot (2.1.4), пытающееся использовать Spring Cloud Streams для Kafka. Я...

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

Можно ли использовать интерактивный запрос (InteractiveQueryService) в Spring Cloud Stream для...