@Override
    public Map<TaskName, Set<SystemStreamPartition>> group(Set<SystemStreamPartition> ssps) {
      Set<SystemStreamPartition> filteredSsps = new HashSet<>();
      for (SystemStreamPartition ssp : ssps) {
        Set<Integer> partitions = getPartitions(ssp.getSystemStream());
        if (partitions.contains(ssp.getPartition().getPartitionId())) {
          filteredSsps.add(ssp);
        }
      }
      HashMap<TaskName, Set<SystemStreamPartition>> group = new HashMap<>();
      group.put(new TaskName("TestTask"), filteredSsps);
      return group;
    }
Comma separated list of partitions that needs to be assigned to this task.
samza-tools/src/main/java/org/apache/samza/tools/benchmark/ConfigBasedSspGrouperFactory.java