Major Description
Currently the StreamPartitionAssignor's "assign" method does not handle cases where we don't have tasks for a particular topic group. E.g., code like this might give an NPE:
"for (TaskId task : tasksByTopicGroup.get(topicGroupId))"
We need to handle the above cases.
Attachments
Issue Links
- links to
