Welke Kafka-component zorgt ervoor dat dezelfde berichten niet opnieuw worden gelezen?

In Kafka wordt het voorkomen van herhaalde lezing van dezelfde berichten verzekerd door het offset-mechanisme en het beheer ervan aan de kant van de consument.

Elk bericht in een partitie heeft een uniek offset — een volgnummer. De consument houdt bij welk offset hij al heeft gelezen en bevestigt (commit). Bij herstart begint de consument te lezen vanaf de laatste bevestigde offset, waardoor herlezing van al verwerkte berichten wordt voorkomen.

Dus, de component die verantwoordelijk is voor het voorkomen van herlezing, is de consument zelf, die de commit-offsets beheert.