public Set<SystemStreamPartition> getSystemStreamPartitions() {
    return systemStreamPartitions;
  }
Returns the {@link SystemStreamPartition}s that this task is responsible for consuming.
@return {@link SystemStreamPartition}s for this task
samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java