@Override
  public SystemStreamPartitionGrouper getSystemStreamPartitionGrouper(Config config) {
    return new ConfigBasedSspGrouper(config);
  }
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