En Kafka, la prevención de la lectura repetida de los mismos mensajes se garantiza mediante el mecanismo de desplazamientos (offsets) y su gestión en el lado del consumidor.

Cada mensaje en una partición tiene un offset único, que es un número de orden. El consumidor realiza un seguimiento del offset que ya ha leído y lo confirma (commit). Cuando se reinicia, el consumidor comienza a leer desde el último offset confirmado, evitando así la lectura repetida de mensajes ya procesados.

Por lo tanto, el componente responsable de prevenir la lectura repetida es el propio consumidor, que gestiona los offsets de confirmación.

Anterior Siguiente