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

2 Respuestas

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
0 votos

I am a General Manager of Store Operations and responsible for day to day store operations, including scheduling, training, and supervising employees and assistant manager. Before that, I worked as a casual Customer Service Representative, In - store consultant, and ROC Coordinator. Air bar box, Clear eyes, Eagle torch lighters, Duracell batteries, haze xl disposable vape, puff xtra limited, recharging puff bar, top shine disposable, supreme hyppe max flow and wax pen batteries are among the items for sale. Managing shop profitability as well as all controllable expenses such as labor, inventory levels, and cash and inventory shortages.

 

por