private SSPMetadataCache getSspCache(SystemAdmins admins, Clock clock, Set<SystemStreamPartition> ssps) {
    if (sspCache == null) {
      sspCache = new SSPMetadataCache(admins, Duration.ofSeconds(5), clock, ssps);
    }
    return sspCache;
  }
Shared cache across KafkaRestoreManagers for the Kafka partition

@param admins system admins used the fetch the stream metadata
@param clock for cache invalidation
@param ssps SSPs to prefetch
@return SSPMetadataCache containing the partition metadata
samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java