Quel composant de Kafka assure la prévention de la relecture des mêmes messages?

En Kafka, la prévention de la relecture des mêmes messages est assurée par le mécanisme de décalages (offsets) et leur gestion côté consommateur.

Chaque message dans une partition a un offset unique, un numéro de série. Le consommateur suit l'offset qu'il a déjà lu et le confirme (commit). Lors du redémarrage, le consommateur commence à lire à partir du dernier offset confirmé, évitant ainsi la relecture des messages déjà traités.

Ainsi, le composant responsable de la prévention de la relecture est le consommateur lui-même, qui gère les offsets de commit.