@Override
  public void close() {
    getListener().onClose(this);
  }
@Test
  public void shouldNotCloseKafkaStreamsOnClose() {
    // When:
    sandbox.close();

    // Then:
    verifyNoMoreInteractions(kafkaStreams);
  }