Я описал входы и выходы 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 для...