838 B
838 B
aliases | tags | date | zero-link | parents | linked | |||||
---|---|---|---|---|---|---|---|---|---|---|
|
|
|
|
- Брокер не отслеживает чтение потребителями
- Потребители могут использовать Kafka для сохранения позиции смещения
- Фиксация (commit) - действие по обновлению текущей позиции потребителя.
- Потребители отправляют в специальную тему
__consumer_offsets
сообщение, содержащее смещение для каждого раздела - Аварийный сбой потребителя или присоединение нового потребителя инициирует ребалансировку.