доку, пишут:
The assignment of partitions to tasks never changes;
Получается если у меня было tasks.max=2 то если я потом изменю на 3 и запущу ещё один тред/instance, ничего не поменяется?
насколько я помню, к-во тасков по всем узлам (в общем случае) равно количеству partitions. таски исполняются пулом тредов, размер которого можно изменять. вместо одного треда на N тасков будет больше тредов. в предельном случае получится по треду на 1 таск
но поскольку вы упоминаете tasks.max, возможно, речь идет о kafka connect?
Я совершенно по другому понял доку кафка стримс. Там написано что как раз каждый таск может читать несколько топиков, но вот это разбиение кому какие топики достанутся неизменно, в том смысле что было например два таска как два отдельных инстанса приложения, один инстанс помер, второй откроет еще один тред и начнет работать над партициями помершего таска. Из этого выходит что их количество поменять нельзя
Обсуждают сегодня