одновременно?
То есть оно всегда читает, доходит до конца топологии, и потом читает следующее?
Или работает в режиме конвейера - то есть читает, после того как прошли первые таски топологии, то читает уже следующее и так далее?
Если топология ветвистая, то могут ли в теории те кто идут более короткими ветками дойти до финиша ранее чем те кто идут более длинными?
топология запускается в тасках, кол-во тасков равно кол-ву партиций во входном топике. т.о. может если сообщения из разных партиций
Обсуждают сегодня