SS
Если падает не лидер, то все работает с задержкой 1,5 сек
Size: a a a
2021 June 23
SS
И консьюмер вроде можно статически прибить к партиции . Не ?
SS
Ок. Спасибо
SS
И ещё. Какие у кого есть временные задержки на время выбора лидера ?
SS
Какими параметры можно использовать для ускорения процесса?
АА
всем привет. подскажите может кто делал kafka connect sink?
АА
мне надо в db2 данные класть
SS
Понятно. Но разве не могу считывать офсеты без коммита?
ЧП
В общем случае это неверно
В группе каждому консьюмеру даётся набор партиций, и он без коммита может сколь угодно долго читать из них. Пока не завершит работу, или не будет реьаланса или он не закоммитит
В группе каждому консьюмеру даётся набор партиций, и он без коммита может сколь угодно долго читать из них. Пока не завершит работу, или не будет реьаланса или он не закоммитит
ЧП
Если конечно не стоит авто.коммит
SS
Автокоммит выключен
ЧП
Считывать оффсеты?
А зачем?
А зачем?
SS
Попробую объяснить . У меня идет входящий поток сигналов, все хорошо обрабатывается . Падает не лидер - все хорошо. Пауза 1.5 сек - норм. Падает лидер… Пауза 8 сек. - не норм. Поэтому в процессе выборов хочу считывать поток, пусть и не коммитить. Главное конечное приложение не будет иметь большой паузы
SS
Как то так. Постарался внятно
SS
Сигналы в Кафке хочу продолжать обрабатывать
ЧП
Ну то есть не оффсеты а сами сообщения. Верно?
SS
Верно