2000 партиций распределятся по 20 воркерам
так, еще раз - воркер прочитал партицию, обновился индекс. Чтобы вместо 10 воркеров сделать 20 надо всех стопнуть и стартовать по новой, чтобы они разбежались?
если в процессе обсчета какой-то воркер упал - все его партиции тормознулись, и тут мы решили проскейлиться и уже никогда не узнаем кто когда то сдох, так?