Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Requisito: Filtrar datos del tema de Kafka en función de un ID. Necesito crear una API y, en función de la entrada proporcionada, debo filtrar los datos de los mensajes presentes en el tema de Kafka en ese momento. Ejemplo: A continuación se muestran los registros presentes en el tema: . . . Read more
¿Alguien aquí tiene experiencia en implementar una aplicación KStream/KsqlDb con un Persistent State Store en un entorno de Kubernetes sin perder la escalabilidad automática? Es decir, ¿es posible la creación automática de un volumen de almacenamiento para el state store y la generación del estado para un nuevo contenedor, así . . . Read more
En spring-boot application.yml: kafka: bootstrap-servers: localhost:9092 listener: concurrency: 10 ack-mode: MANUAL producer: topic: test-record key-serializer: org.apache.kafka.common.serialization.StringSerializer value-serializer: org.springframework.kafka.support.serializer.JsonSerializer retries: 3 orn-record: timeout: 3 #acks: 1 consumer: groupId: test-record topic: test enable-auto-commit: false key-deserializer: org.apache.kafka.common.serialization.StringDeserializer value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer Al utilizar la configuración anterior, podemos evitar la configuración basada en Java web (bean) . . . Read more
Tengo 2 aplicaciones de Spring Boot. Estoy tratando de mapear en el archivo application.properties de tal manera que el Consumidor pueda recibir el mensaje enviado por el productor. Quiero agregar que estoy usando un CustomMessage: public class CustomMessage { private LocalDateTime timestamp; private Integer idSensor; private Double valor_medicion; // getters . . . Read more
¿Existe alguna forma para que un administrador de Kafka pueda saber si algunos offsets expiraron antes de que el consumidor lograra procesarlos y confirmarlos, debido a la retención establecida en un tema, sin la ayuda de los registros del lado del cliente? También hay una pregunta sobre cómo mejorar la . . . Read more