@Override
  public void configure(final KsqlConfig config) {
    if (!config.getKsqlStreamConfigProps().containsKey(StreamsConfig.APPLICATION_SERVER_CONFIG)) {
      throw new IllegalArgumentException("Need KS application server set");
    }
    this.primaryContext.configure(config);
  }
@Test
  public void shouldThrowIfConfigureNotCalledWithAppServerConfig() {
    // When/Then:
    setupKsqlEngineWithSharedRuntimeEnabled();
    assertThrows(IllegalArgumentException.class, () -> ksqlEngine.configure(KsqlConfig.empty()));
  }