@Override
  public Map<String, SystemStreamMetadata> getSystemStreamMetadata(Set<String> streamNames) {
    return streamNames.stream().collect(Collectors.toMap(Function.identity(), this::createSystemStreamMetadata));
  }
Source of truth for checkpointing is always kinesis and the offsets given by samza are always ignored by KCL.
Hence, return a placeholder for each ssp.
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemAdmin.java