AU
но старые данные останутся в старых
Size: a a a
2021 November 25
TS
это как мир остановить
AU
странно
AU
все должно перезапускаться, иначе это чет не то
AU
тем более сервисы которые читают или пишут в очередь
TS
ты можешь на 1 топик натравить несколько консюмер групп, тогда в каждой группе для каждой партиции у тебя будет отдельный оффсет
AU
в офф документации все это есть
консюмер группа это просто кусок стейта в zookeeper +- в котором хранятся локи клиентов и текущий оффсет
консюмер группа это просто кусок стейта в zookeeper +- в котором хранятся локи клиентов и текущий оффсет
TS
ну как заставить людей не покупать в черную пятницу? разве что заранее заскейлить кафку и заранее перезапустить интернет магазин. будет простой
AU
сервисы по одному перезапускаются
TS
к сожалению доки уродские у кафки, и не все там очевидно
AU
тру
AU
перезапуск скорее всего не будет нужен, я не помню точно, но емнип роутинг мессаги в партицию по ключу делает сама кафка
AU
так что если добавить партицию - для продьюсеров не поменяется вообще ничего
AU
а для консьюмеров - они просто не будут видеть новую партицию какое-то время пока ребаланс не пройдет
TS
роутинг на стороне продюсера происходит
TS
если “сама кафка” имеется в виду “клиент кафки”, то согласен. просто я вот не знаю точно, умеет ли клиент узнавать без перезапуска, что партиция появилась
AU
консьюмеры - точно да
AU
так что думаю и продьюсеры тоже
SS
есть чат по кафке https://t.me/proKafka
TS
вот все что нужно знать про dynamic membership ))