private SystemStreamMetadata.SystemStreamPartitionMetadata getMetadata() {
      return metadata;
    }
Nullable so that we can cache that there was no metadata for the last fetch.
samza-core/src/main/scala/org/apache/samza/system/SSPMetadataCache.java