@Override
  public void stop() {
    stop(true);
  }
@Test
    @SuppressFBWarnings("RV_RETURN_VALUE_IGNORED_NO_SIDE_EFFECT")
    public void shouldCloseKafkaStreamsOnStop() {
        // When:
        query.stop();

        // Then:
        final InOrder inOrder = inOrder(sharedKafkaStreamsRuntimeImpl);
        inOrder.verify(sharedKafkaStreamsRuntimeImpl).stop(QUERY_ID, true);
        inOrder.verifyNoMoreInteractions();
    }