консьюмить данные ?
А как тогда трекать новые офсеты?
Это вопрос на ответ
Каждый раз, когда читается рекорд, надо комитить офсет, иначе в следующий раз потребитель из той же консьюмер группы получит тот же рекорд снова и так до бесконечности. «Закомитить» — это операция на запись, поэтому нужен лидер.
Понятно. Но разве не могу считывать офсеты без коммита?
В общем случае это неверно В группе каждому консьюмеру даётся набор партиций, и он без коммита может сколь угодно долго читать из них. Пока не завершит работу, или не будет реьаланса или он не закоммитит
Считывать оффсеты? А зачем?
Сигналы в Кафке хочу продолжать обрабатывать
Читать можно, но зачем это? Я не очень понимаю сценарий использования.
Но тогда он обречён их перечитывать заново при любой проблеме с сетью.
Сценарий простой. Обрабатывать сообщения с паузой максимум 2 сек при падении любого из трёх брокеров кластера
нет
я так вижу, опять в чате хотят 100% аптайма бесплатно )
Классика ответа - нет. Типично. Без объяснений или ссылок. Спасиб
Вы не читали kafka 101, приходите с вопросами которые покрыты 100 раз вдоль и поперек
Обсуждают сегодня