Size: a a a

2021 November 25

SS

Shamil Sabirov in Astana JKUG
это только через кафку. и producer'ов
источник

SS

Shamil Sabirov in Astana JKUG
насчет это я чесно говоря не был уверен раньше. но если так - тогда ок. все складывается
источник

TS

Tair Sab in Astana JKUG
на лету можно поменять?
источник

TS

Tair Sab in Astana JKUG
ок, тогда объясни, почему мое решение не масштрабируется?
источник

SS

Shamil Sabirov in Astana JKUG
если кафка и консюмеры в кластере, то почему бы и нет? ну ессно кол-во партиций нужно будет подгонять, увеличивать. но если кафка в кластере то простой минимальный будет. со стороны кафки
источник

TS

Tair Sab in Astana JKUG
“простой” и “на лету” это немного разные вещи вообще то
источник

SS

Shamil Sabirov in Astana JKUG
да признаю что со стороны кафки нужен "простой"
источник

SS

Shamil Sabirov in Astana JKUG
хотя в случае кластера кафка это будет минимизировано
источник

TS

Tair Sab in Astana JKUG
ок, давай я задам несколько вопросов, чтобы ты понял, в чем ты не прав:
1. сколько консюмеров могут одновременно читать из 1 топика?
2. сколько оффсетов в 1 консюмер-группе?
3. какое отношение между сущностями “партиция” и “активный консюмер”? варианты: (а) one-to-many, (b) many-to-many, (c) many-to-one

“активный консюмер” — это консюмер, которому активно доставляются сообщения. в отличие от “пассивного консюмера”, который стоит на стреме
источник

SS

Shamil Sabirov in Astana JKUG
1. только один
2. у каждой партиции свой офсет. каждый консюмер знает свой топик и partition. а в группе может быть несколько consumer
3. не корректный вопрос, тут нельзя точно сказать какой консюмер из какого топика и из какой партиции может выбрать  следующее сообщение. consumer-group->consumer->topic->partition
источник

TS

Tair Sab in Astana JKUG
1. из одного топика могут одновременно читать не более N консюмеров, где N = кол-во партиций в данном топике
2. у каждой партиции в рамках консюмер-группы свой офсет,каждый консюмер знает своИ топикИ и партициИ в этих топиках. Например у партиции может быть несколько оффсетов, но они все будут в разных группах.
3. в рамках одной консюмер-группы отношение many-to-one.
источник

TS

Tair Sab in Astana JKUG
получается, чтобы масштабировать мое решение, достаточно накинуть еще много инстансов, но одновременно получать сообщения будут только N инстансов, где N = кол-во партиций
источник

AU

Anton U in Astana JKUG
партиции можно вроде скейлить вверх ( то есть докинуть партиций )
вот убрать - не выйдет
источник

TS

Tair Sab in Astana JKUG
продюсеров придется перезапустить же
источник

TS

Tair Sab in Astana JKUG
разве нет?
источник

AU

Anton U in Astana JKUG
да, конечно, но это вряд ли проблема
источник

AU

Anton U in Astana JKUG
там есть другой проблемный поинт - что очередность потеряется
источник

AU

Anton U in Astana JKUG
после добавления нового партишна изменится маппинг от ключей к партициям
источник

TS

Tair Sab in Astana JKUG
чаще как раз в том и проблема, что продюсеров нельзя перезапускать
источник

SS

Shamil Sabirov in Astana JKUG
2. у каждой партиции в рамках консюмер-группы свой офсет,каждый консюмер знает своИ топикИ и партициИ в этих топиках. Например у партиции может быть несколько оффсетов, но они все будут в разных группах.

ето как? естьоффициальная документация? как по мне такого не может быть и не должно...
источник