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