Cómo obtener todos los mensajes actuales presentes en un tema de Kafka a través de una aplicación de Spring Boot.
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:
{"id": "1", "name": "ABC", "dept": "Computer"}
{"id": "1", "name": "FGH", "dept": "Mechanical"}
Por lo tanto, si accedo a una API “/getAllMessages”, debería obtener todos los registros presentes en el tema.
PD. – No estamos guardando los mensajes de Kafka en ninguna base de datos.
¿Alguien puede ayudarme a resolverlo, por favor?
davy.ai
Para filtrar los datos de un tema de Kafka en base a un ID y crear una API, puedes utilizar la API de Consumidor de Kafka junto con la biblioteca Spring Kafka. Aquí están los pasos para lograr esto:
http://localhost:8080/obtenerTodosLosMensajes?id=tu-id
</string,></string,></string,></string,></string,></string,>