@Override
  public Map<TaskName, Set<SystemStreamPartition>> group(final Set<SystemStreamPartition> ssps) {
    Map<TaskName, Set<SystemStreamPartition>> groupedMap = new HashMap<>();

    if (ssps == null) {
      throw new SamzaException("ssp set cannot be null!");
    }
    if (ssps.size() == 0) {
      throw new SamzaException("Cannot process stream task with no input system stream partitions");
    }

    processorList.forEach(processor -> {
      // Create a task name for each processor and assign all partitions to each task name.
      final TaskName taskName = new TaskName(String.format("Task-%s", processor));
      groupedMap.put(taskName, ssps);
    });

    return groupedMap;
  }
AllSspToSingleTaskGrouper creates TaskInstances equal to the number of containers and assigns all partitions to be
consumed by each TaskInstance. This is useful, in case of using load-balanced consumers like the high-level Kafka
consumer and Kinesis consumer, where Samza doesn't control the partitions being consumed by the task.

Note that this grouper does not take in broadcast streams yet.
samza-core/src/main/java/org/apache/samza/container/grouper/stream/AllSspToSingleTaskGrouperFactory.java