@Test(expected = SamzaException.class)
  public void testGetMetadataExceptionFirstFetch() {
    SystemStreamPartition ssp = buildSSP(0);
    SSPMetadataCache cache = buildSSPMetadataCache(ImmutableSet.of(ssp));
    when(clock.currentTimeMillis()).thenReturn(10L);
    when(systemAdmin.getSSPMetadata(ImmutableSet.of(ssp))).thenThrow(new SamzaException());
    cache.getMetadata(ssp);
  }
Given that the admin throws an exception when trying to get the metadata for the first time, getMetadata should
propagate the exception.
samza-core/src/test/java/org/apache/samza/system/TestSSPMetadataCache.java