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

    readWriteStore.delete(toReadWriteStoreKey(ssp, taskName));
    readWriteStore.flush();
  }
Deletes the {@link Startpoint} for a {@link SystemStreamPartition} and {@link TaskName}.
@param ssp ssp The {@link SystemStreamPartition} to delete the {@link Startpoint} for.
@param taskName ssp The {@link TaskName} to delete the {@link Startpoint} for.
samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java