@Override
  public void shutdown() {
    try {
      ksqlEngine.close();
    } catch (final Exception e) {
      log.warn("Failed to cleanly shutdown the KSQL Engine", e);
    }
    try {
      serviceContext.close();
    } catch (final Exception e) {
      log.warn("Failed to cleanly shutdown services", e);
    }
  }
@Test
  public void shouldCloseServiceContextOnStop() {
    // When:
    standaloneExecutor.shutdown();

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