Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy utilizando la versión 3.0.6.RELEASE de Spring Cloud Stream. Tengo un exchange existente llamado “my.queue.exchange”. Mi aplicación contiene un consumidor, quiero crear una cola llamada “MY_QUEUE” y enlazar esa cola al exchange “my.queue.exchange”. Además, quiero republicar los mensajes fallidos en una DLQ llamada “MY_QUEUE_DLQ”. Mi problema es que la cola . . . Read more
Estoy desarrollando una aplicación de enrutador (proxy de eventos) con Spring Cloud Stream sobre Kafka, en el paradigma funcional. La aplicación consume de un tema de entrada constante, mapea y filtra el mensaje y luego debería enviarlo a algún tema de acuerdo con algunos campos de entrada (solo un mensaje . . . Read more
Desarrollamos un marco interno de la empresa sobre Spring Boot y nos gustaría compatibilizar Kafka-Streams con Spring Cloud Stream. Necesitamos inyectar automáticamente algunos encabezados en todos los mensajes salientes. Hemos logrado esto con el Binder Kafka de Spring Cloud Stream al registrar un ChannelInterceptor personalizado, pero esto no funciona para . . . Read more
Tenemos un microservicio que lee registros de varios temas de Kafka. Para cada tema de entrada, tenemos un tema de DLQ separado para almacenar registros que no se pudieron procesar por cualquier motivo (formato de registro no válido, los registros no se pudieron analizar utilizando el esquema Avro, no se . . . Read more
Hice una aplicación de Spring Batch que produce mensajes AMQP (RabbitMQ) que consisten en una lista de objetos JSON. Los mensajes tienen encabezados con metadatos. La aplicación de Spring Cloud Stream está consumiendo los mensajes y utilicé un enfoque funcional. ¿Cómo puedo acceder a los encabezados? ¿Es una mala práctica . . . Read more