List<SystemStreamPartition> createSSPs(String systemName, String physicalStreamName, int startPartition,
      int endPartition) {
    return IntStream.range(startPartition, endPartition)
        .mapToObj(x -> new SystemStreamPartition(systemName, physicalStreamName, new Partition(x)))
        .collect(Collectors.toList());
  }
Simple implementation to create SSPs that assumes that the partitions are ordered list of integers.
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemProducerBench.java