public void removeFanOutForTask(TaskName taskName) {
    Preconditions.checkState(!stopped, "Underlying metadata store not available");
    Preconditions.checkNotNull(taskName, "TaskName cannot be null");

    fanOutStore.delete(toFanOutStoreKey(taskName));
    fanOutStore.flush();
  }
Deletes the fanned out {@link Startpoint} for the given {@link TaskName}
@param taskName to delete the fan out Startpoints for
samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java