Всем привет, подскажите пожалуйста по насчёт Kafka consumers и consumer

group.

Есть приложение, в котором 2 топика обрабатываются 2 консьюмерами индивидуально, т.е. 1-1, каждый топик это определённый тип сообщений. Сейчас консьюмеры находятся в одной группе.

Как я понимаю, если произойдёт ребалансировка партиций этих топиков (по разным причинам, или консьюмер упал или сами пошли ручками в кафке поменяли кол-во партиций) - то у меня возникает проблема что часть партиций может
уйти на консьмер, который не ожидает такой тип сообщений - верно же? https://stackoverflow.com/questions/57753211/kafka-use-common-consumer-group-to-access-multiple-topics

При этом в Kafka Definitive Guide читаю что обычная практика назначать consumer group per application

Как вы разруливаете вариант когда приложение обрабатывает несколько топиков?

2 ответов

6 просмотров

hi. разные консумер фактори и, соотвественно, лиснер контайинер фактори (там уже разные пропсы под каждый топик (консумера офк) и логику обработки, аск и прочее). а почему нельзя разбить на 2 апликейшина?

Eugene-Zakharov Автор вопроса
Ivan Knyazev
hi. разные консумер фактори и, соотвественно, лисн...

Не хочу лишний контейнер деплоить. В целом я понял, спасибо

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

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

Добрый день, не подскажите, если в OC-V3 поменять страндартную директорию /storage/ на /storage2/ - не будет сильно много проблем ?
Max Dubovsky
32
'frakturBold' => ['𝖆', '𝖇', '𝖈', '𝖉', '𝖊', '𝖋', '𝖌', '𝖍', '𝖎', '𝖏', '𝖐', '𝖑', '𝖒', '𝖓', '𝖔', '𝖕', '𝖖', '𝖗', '𝖘', '𝖙', '𝖚', '𝖛', '𝖜', '𝖝', '𝖞', '𝖟', '𝕬', '𝕭', '𝕮', '𝕯'...
Roma
4
Всем привет. Нужна платная консультация от тех, кто сталкивался с октябрём в кластере или шарит оч хорошо в цмс. Проблема следующая: после переноса в кластер октябрь начал ...
wl
8
Каким то образом можно определить ширину экрана пользователя перед загрузкой partial-а? Надо рассчитать ширину кадров слайдера для ресайза картинок для container-fluid.
Point 111
22
а я честно сказать не понимаю - нахуя идти учиться на вышку или еще куда-либо и при этом нихуя не делать, типа зачем ? просто корку получить, а нахуй она нужна тогда ?
Eugene Неелов
7
А сколько часов мак держит зарядку в рабочем режиме? Например мой Redmi Mac (просто наклейка от айфона осталась, налепил) по началу держал часов 5 с парой открытых штормов и ...
Ross
8
Ребят, а вот такой вопрос: если я владелец бота анонимного чата, в котором, например, имеются подписки, используя какую-нибудь ЮКассу (или тому подобное, в общем с налогами, в...
Eugene Неелов
8
зараз якщо створити файл core/custom/define.php з текстом <?php const NO_SESSION = true; можна позбутися сесійних кукі (що зручно, щоб не показувати людям банери про збір та в...
Artur Kyryliuk
1
Ребят, было ли у вас так, что переменные в WebApp —tg-viewport-height, —tg-viewport-stable-height после метода expand не обновляются, а остаются в размерах, как было до expand...
Black
3
я бы даже сказал не размер резюме, а слова, которые там написаны, потому что резюме может быть на несколько десятков страниц из-за 20 летнего опыта работы, но там в опыте буде...
Eugene Неелов
2
Карта сайта