Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Debido a que @EnableBinding y @StreamListener están obsoletos, necesito migrar el código existente al nuevo modelo, sin embargo no pude encontrar ninguna información sobre si el mapeo de argumentos disponible en Spring Cloud Stream todavía es compatible y/o si hay soluciones alternativas limpias. Mi método original: @StreamListener(“mysource”) public void processMessage(byte[] . . . Read more
Estoy actualizando una aplicación Spring Boot a Boot 2.6.1, Cloud 2021.0.0 y Cloud Stream 3.2.1. Esta aplicación tiene una serie de KStreams como: @Bean fun processEvent(): Function<><id, eventreceived=””>, KStream<id, updatedinfo?=””>> { … } Ahora la aplicación se bloquea al iniciar: Caused by: org.springframework.kafka.KafkaException: No se pudo iniciar el stream; la . . . Read more
Soy nuevo en Spring cloud stream. Digamos que tengo una aplicación de Spring cloud stream que escucha un tema de Kafka usando @StreamListener(“input-channel”). Quiero hacer algunos cálculos y enviar el resultado a otro tema, pero en medio del procesamiento también necesito llamar a Hibernate (a través de spring data jpa) . . . Read more
Estoy utilizando Spring Cloud (Hoxton.SR8) Stream con el vinculador de Kafka-Streams en mi proyecto. ¿Podemos verificar el encabezado del mensaje antes de deserializar la carga útil? Quiero hacer esto para lograr un filtro basado en el encabezado de los mensajes entrantes. La deserialización puede consumir algo de CPU, antes de . . . Read more
Mi requisito es completamente igual a lo que se describe aquí https://stackoverflow.com/questions/59135268/there-are-producer-issues-with-spring-cloud-stream-3-0 por @hero-zh. Encontré que @Oleg Zhurakousky sugiere usar StremBridge, pero cuando examiné la clase, hay @SuppressWarnings(“deprecation”) agregado a nivel de clase. Lo cual significa que esta clase pronto quedará obsoleta. Estoy buscando una alternativa de StreamBridge que pueda . . . Read more