@Override
  public synchronized void close() {
    log.info("Closing validation runtime {}", getApplicationId());
    kafkaStreams.close();
    kafkaStreams.cleanUp();
  }
@Test
  public void shouldCloseRuntime() {
    //When:
    validationSharedKafkaStreamsRuntime.close();

    //Then:
    verify(kafkaStreamsNamedTopologyWrapper).close();
  }