@Override
  public synchronized void close() {
    kafkaStreams.close();
    kafkaStreams.cleanUp();
  }
@Test
    public void shouldCloseRuntime() {
        //When:
        sharedKafkaStreamsRuntimeImpl.close();

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