Resultados de la búsqueda a petición "spring-cloud-stream"
¿Cómo se puede configurar @MessagingGateway con Spring Cloud Stream MessageChannels?
He desarrollado servicios asincrónicos de Spring Cloud Stream, y estoy tratando de desarrollar un servicio perimetral que use @MessagingGateway para proporcionar acceso sincrónico a servicios que son asíncronos por naturaleza. Actualmente estoy ...
Spring Data Flow con 2 fuentes que alimentan un procesador / sumidero
Estoy buscando algunos consejos sobre cómo configurar un flujo de Spring Data Flow para un caso de uso específico. Mi caso de uso: Tengo 2 RDBMS y necesito comparar los resultados de las consultas ejecutadas en cada uno. Las consultas deben ...
¿Cuáles son los beneficios de Spring Cloud Dataflow?
Según lo que he visto, la creación de un flujo en Spring Cloud Dataflow (SCDF) desplegará las aplicaciones subyacentes, vinculará el servicio de comunicación (como RabbitMQ), establecerá las variables de entorno de Spring Cloud Stream e iniciará ...
¿Los mensajes de piedra sepulcral no eliminan el registro de la tienda de estado de KTable?
Estoy creando datos de procesamiento de KTable desde KStream. Pero cuando disparo mensajes de lápida con clave y carga útil nula, no se elimina el mensaje de KTable. sample - public KStream<String, GenericRecord> ...
patrón de mensajería spring-cloud-stream solicitud-respuesta
¿Hay un patrón de solicitud-respuesta que uno debería usar con spring-cloud-stream? Toda la documentación que puedo encontrar en spring-cloud-stream está dirigida al MessageChannel.send tipo de productor de disparar y olvidar, y estoy ...
Spring Cloud Stream @SendTo Anotación no funciona
Estoy usando Spring Cloud Stream con Spring Boot. Mi aplicación es muy simple: ExampleService.class: @EnableBinding(Processor1.class) @Service public class ExampleService { @StreamListener(Processor1.INPUT) @SendTo(Processor1.OUTPUT) public ...
Fuente Kafka en el flujo de datos de Spring Cloud
Estoy migrando de Spring XD a Spring Cloud Data Flow. Cuando busco la lista de módulos, me di cuenta de que algunas de las fuentes no figuran en Spring Cloud Flow. Una de ellas es la fuente KAFKA. Mi pregunta es ¿por qué la fuente KAFKA se ...
Mensaje de Spring Cloud Stream desde / a la configuración de conversión JSON
Estoy usando Spring Cloud Stream, con la carpeta RabbitMQ. Funciona muy bien conbyte[] carga útil y serialización nativa de Java, pero necesito trabajar con la carga útil JSON. Aquí está mi clase de procesador. @EnableBinding(Processor.class) ...
La prueba de arranque de primavera falla diciendo: No se puede iniciar ServletWebServerApplicationContext debido a la falta de ServletWebServerFactory bean
Clase de prueba: - @RunWith(SpringRunner.class) @SpringBootTest(classes = { WebsocketSourceConfiguration.class, WebSocketSourceIntegrationTests.class }, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, properties = ...
Spring Cloud Stream para soportar mensajes de enrutamiento dinámicamente
Quiero crear un proyecto común (usando Spring Cloud Stream) para enrutar mensajes a diferentes proyectos (consumidores) dinámicamente de acuerdo con el contenido del mensaje. (rabbitmq como el agente de mensajes) ¿Spring Stream lo soporta? si ...