Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Actualmente estoy recibiendo mensajes de Kafka y la carga útil es protobuf. Se utiliza un convertidor de mensajes personalizado para decodificar el contenido antes de pasarlo a mi función. Lo que estoy intentando hacer ahora es inspeccionar la carga útil entrante y descartar condicionalmente el mensaje si no es lo . . . Read more
Tengo la siguiente configuración en application.yml para mi aplicación Spring Cloud Stream Kafka: spring: cloud: function: definition: userBinding stream: kafka: binder: broker: localhost:9092 replicationFactor: 1 bindings: userBinding-in-0: destination: user y la siguiente función consumidora que debe ser llamada: @Bean public Consumer<><usermodel>> userBinding() { return message -> { System.out.println(“Recibido:” + message); . . . Read more
Si el userProducer se coloca en una clase separada, no se está activando, por ejemplo a través de StreamBridge. package com.moments.auth; import com.moments.auth.payload.UserEventPayload; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.stream.annotation.EnableBinding; import org.springframework.context.annotation.Bean; import java.util.function.Function; import java.util.function.Supplier; @SpringBootApplication public class AuthApplication { public static void main(String[] args) { SpringApplication.run(AuthApplication.class, args); } @Bean . . . Read more
Estoy usando Spring Cloud Stream Binder para Kinesis con KPL/KCL habilitado. Nos gustaría desactivar las métricas de Cloudwatch sin tener que manejar la configuración de KPL y KCL nosotros mismos (anulando completamente los beans). Nos gustaría utilizar la misma definición de bean para la KinesisProducerConfiguration y cada una de las . . . Read more
Aquí está mi situación: Tenemos un servicio Spring cloud Stream 3 Kafka conectado a múltiples topics en el mismo broker, pero quiero controlar la conexión a un topic específico basado en propiedades. Cada topic tiene su propio binder y binding, pero el broker es el mismo para todos. Intenté desactivar . . . Read more