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

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

Я локально запускаю приложение (Spring Boot и Spring Cloud Stream, Kafka Binder и Kafka Streams...

Я пытаюсь создать самый простой мир привет с помощью Spring Cloud + Kafka Streams + Spring Boot 2....

Мы используем Spring Cloud Streams, которые слушают тему Кафки и вызывают службу отдыха.Мы также...

Я хотел бы протестировать Spring Cloud Stream с регистрацией Confluent Schema и эволюцией Avro...

Я хочу установить свойство acks = all для моего производителя в моем приложении весеннего облачного...

Я бы хотел настроить стратегию именования субъектов схемы Avro в источниках, потребителях и...

Описание Я пытаюсь понять, почему пропускная способность sync rest api в ~ 6 раз хуже, чем async...

Примеры приложений для проверки этого можно найти в https://github

Я использовал spring-cloud-starter stream-kafka для подключения к kafka, версия 2.1.2.Когда я...

У меня есть приложение (spring-boot-shipping-service) с KStream, которое получает сообщения...

Я использую Spring Cloud Stream kafka для обмена сообщениями.Когда я помещаю потребителя и...

Обобщение проблемы В моем проекте мы пытаемся использовать Spring-Cloud-Stream (SCS) для...

Предположим, что приложение Spring Cloud Stream создает KStream из order topic.Интересует...

Это мое приложение, которое просто получает ссылку на KStream из темы клиента (привязка ввода) и...

Я использую пружинный механизм связывания для приема сообщений в пакетном режиме Иногда я не могу...

Я использую Spring Cloud Stream вместе с реестром схемы Aiven , который использует реестр схемы...

У меня есть приложение, которое подключается к RabbitMQ через Spring Cloud Stream, которое отлично...

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

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

Я строю конвейер данных с приложением Spring Cloud Stream File Source в начале конвейера. Мне нужна...

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

У меня есть этот поток: @Bean public IntegrationFlow flow(){ return IntegrationFlows

После обновления с Spring Boot 2.0.6 / Spring Cloud Finchley.RELEASE до Spring Boot 2.1.3 / Spring...