Коллеги, подскажите - возможно ли в процессе выбора лидера, продолжать

консьюмить данные ?

15 ответов

12 просмотров

А как тогда трекать новые офсеты?

暴君IT アーキテクト Shevelev
Это вопрос на ответ

Каждый раз, когда читается рекорд, надо комитить офсет, иначе в следующий раз потребитель из той же консьюмер группы получит тот же рекорд снова и так до бесконечности. «Закомитить» — это операция на запись, поэтому нужен лидер.

暴君IT アーキテクト-Shevelev Автор вопроса
Dead End
Каждый раз, когда читается рекорд, надо комитить о...

Понятно. Но разве не могу считывать офсеты без коммита?

Dead End
Каждый раз, когда читается рекорд, надо комитить о...

В общем случае это неверно В группе каждому консьюмеру даётся набор партиций, и он без коммита может сколь угодно долго читать из них. Пока не завершит работу, или не будет реьаланса или он не закоммитит

暴君IT アーキテクト-Shevelev Автор вопроса
Чёрный Плащ
Считывать оффсеты? А зачем?

Сигналы в Кафке хочу продолжать обрабатывать

暴君IT アーキテクト Shevelev
Понятно. Но разве не могу считывать офсеты без ком...

Читать можно, но зачем это? Я не очень понимаю сценарий использования.

Чёрный Плащ
В общем случае это неверно В группе каждому консь...

Но тогда он обречён их перечитывать заново при любой проблеме с сетью.

暴君IT アーキテクト-Shevelev Автор вопроса
Dead End
Читать можно, но зачем это? Я не очень понимаю сце...

Сценарий простой. Обрабатывать сообщения с паузой максимум 2 сек при падении любого из трёх брокеров кластера

нет

暴君IT アーキテクト Shevelev
Сценарий простой. Обрабатывать сообщения с паузой ...

я так вижу, опять в чате хотят 100% аптайма бесплатно )

暴君IT アーキテクト-Shevelev Автор вопроса
Eugene Bosiakov
я так вижу, опять в чате хотят 100% аптайма беспла...

Классика ответа - нет. Типично. Без объяснений или ссылок. Спасиб

暴君IT アーキテクト Shevelev
Классика ответа - нет. Типично. Без объяснений или...

Вы не читали kafka 101, приходите с вопросами которые покрыты 100 раз вдоль и поперек

Похожие вопросы

Обсуждают сегодня

Добрый вечер, Пока не совсем понимаю как наладить общение между телеграм ботом и ПО для работы с сим боксом. По самому боту так понял: - Нужен некий баланс, который можно поп...
Magic
6
сделал сайт, прикрутил в боте сайт, и виджет логина. как автоматически логинить пользователя в аккаунт(телеграм), при входе с бота?
Александра Чернивецкая
5
Объясните, пожалуйста, почему компилятор ругается на использование в условии неинициализированной переменной: int x; Task.Run(async () => { x = await somefunc(); }).Wait...
Александр
5
Всем привет. Ребята, подскажите, пожалуйста. у ботов есть ограничение на отправку сообщений - 30 сообщений в секунду, эти ограничения накладываются на все сообщения? или на со...
Artem Stormageddon
4
Блин, ребята, сори за тупые вопросы. А можно ли как-то открыть вебапку по нажатию на кнопку в меню(которое появляется слева, команды)?
Artem Stormageddon
3
а плаксы из-под питона умеют только в комфортных условиях что-то выдавить из себя?)
Lencore
9
Но, может, есть уже проверенная? Наши требования такие: 1. Сообщения должны приходить из Инста в CRM оду 2. Должна быть возможность подключить несколько экаунтов Инстаграм. Р...
Alexander Sharoiko MSE / Александр Шаройко
13
Коллеги, может знает кто, можно ли цвет бейджа счётчика в BackendMenu менять без бубнов?
Alex Blaze
3
Это может быть все-таки не флудвейт? у меня ботфазер принимает изменения и отображает даже что они изменились, на видео видно что он прислал якобы уже измененное описание, н...
OVERLINK
13
Привет!) Кто как юзает переменные в строках?) Чисто ради интереса Вот так: echo "У меня {$bananasAmount} бананов"; Или вот так: echo "У меня ${bananasAmount} бананов";
Виталий
3
Карта сайта