public Map<SystemStreamPartition, Startpoint> getFanOutForTask(TaskName taskName) throws IOException {
    return getStartpointFanOutPerTask(taskName)
        .map(startpointFanOutPerTask -> ImmutableMap.copyOf(startpointFanOutPerTask.getFanOuts())).orElse(ImmutableMap.of());
  }
Read the fanned out {@link Startpoint}s for the given {@link TaskName}
@param taskName to read the fan out Startpoints for
@return fanned out Startpoints
samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java