шаблон обмена сообщениями запрос-ответ spring-cloud-stream

Смотрите также мой ответ.

работал асинхронные службы Spring Cloud Stream и пытаюсь разработать пограничный сервис, который использует @MessagingGateway для обеспечения синхронного доступа к асинхронным службам по своей природе. В настоящее время я получаю следующую ...

Сообщение Spring Cloud Stream из / в конфигурацию преобразования JSON

Я использую Spring Cloud Stream, со связующим RabbitMQ. Отлично работает с

Источник Кафки в Spring Cloud Data Flow

Я перехожу с Spring XD на Spring Cloud Data Flow. Когда я искал список модулей, я понял, что некоторые источники не перечислены в Spring Cloud Flow - один из...

Не стесняйтесь принять мой ответ, если он работает сейчас :)

даю данные обработки KTable из KStream. Но когда я запускаю сообщения-захоронения с ключом и нулевой полезной нагрузкой, это не удаляет сообщение из KTable. образец - public KStream<String, GenericRecord> ...

Спасибо! Реализовал это и сделал то, что хотел. Вскоре я задам еще один вопрос об определении источника сообщения в названном месте назначения - на случай, если у вас появятся какие-либо сведения.

Используйте правильное написание, пунктуацию и грамматику в меру своих возможностей.

вый класс: - @RunWith(SpringRunner.class) @SpringBootTest(classes = { WebsocketSourceConfiguration.class, WebSocketSourceIntegrationTests.class }, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = ...

Каковы преимущества Spring Cloud Dataflow?

Исходя из того, что я видел, создание потока в Spring Cloud Dataflow (SCDF) будет развертывать базовые приложения, связывать коммуникационную службу (наприме...

Spring Cloud Stream для поддержки маршрутизации сообщений динамически

Я исправил работу, чтобы избежать ранней инициализации бина.

ользую Spring Cloud Stream с Spring Boot. Мое приложение очень простое: ExampleService.class: @EnableBinding(Processor1.class) @Service public class ExampleService { @StreamListener(Processor1.INPUT) @SendTo(Processor1.OUTPUT) public ...