0 votos
Hace unos meses hemos cambiado nuestro bus de mensajes de tibco EMS a kafka y me estoy dando cuenta que los mensajes dentro de los tópicos no desaparecen como lo hacían en las colas de EMS. Estos mensajes por la información que contiene no son válidos pasados 30sg. Puedo configurar un tópico en kafka para que sea borrado el mensaje cuando es consumido?
por en General

1 Respuesta

0 votos
Buenas José Antonio.

Kafka mantiene los mensajes en el topic y los elimina cuando se cumple el tiempo de retención (configurable desde los brókeres).

Si quieres no volver a leer mensajes repetidos, lo mejor es que todos los consumidores sean del mismo grupo, de este modo, cuando se lea un mensaje del topic, el puntero del grupo se mueve y ningún otro consumidor del mismo grupo los leerá repetidos.

Por otro lado, en Kafka, la responsabilidad de saber qué mensajes se han leído recae en el consumidor, por lo que puedes descartar los mensajes dado alguna condición desde los consumidores por streaming de datos (por ejemplo, cuya caducidad sea de 30 segundos).
por