@Override
  public void stop() {
    stop(true);
  }
@Test
    public void shouldCallKafkaStreamsCloseOnStop() {
        // When:
        query.stop();

        // Then:
        verify(sharedKafkaStreamsRuntimeImpl).stop(QUERY_ID, true);
    }