--- aliases: - offset tags: - зрелость/🌱 date: - - 2024-08-26 zero-link: - "[[00 Kafka]]" parents: linked: --- - Брокер не отслеживает чтение потребителями - Потребители могут использовать Kafka для сохранения позиции смещения - Фиксация (commit) - действие по обновлению текущей позиции потребителя. - Потребители отправляют в специальную тему `__consumer_offsets` сообщение, содержащее смещение для каждого раздела - Аварийный сбой потребителя или присоединение нового потребителя инициирует ребалансировку.