Кой компонент на Kafka осигурява предотвратяване на повторното четене на същите съобщения?

В Kafka предотвратяването на повторното четене на същите съобщения се осигурява чрез механизма за отмествания (offsets) и управлението им от страна на потребителя.

Всяко съобщение в партиция има уникален offset — пореден номер. Потребителят следи кой offset вече е прочетен и го потвърждава (commit). При повторен старт, потребителят започва да чете от последния потвърден offset, като по този начин избягва повторното четене на вече обработени съобщения.

Следователно, компонентът, отговорен за предотвратяване на повторното четене, е самият потребител, който управлява commit offset-ите.