@Override
  public void overrideStreamsProperties(final Map<String, Object> newProperties) {
    newProperties.put(StreamsConfig.APPLICATION_SERVER_CONFIG,
        streamsProperties.get(StreamsConfig.APPLICATION_SERVER_CONFIG));
    //The application server should not be overwritten
    streamsProperties = ImmutableMap.copyOf(newProperties);
  }
@Test
    public void overrideStreamsPropertiesShouldReplaceProperties() {
        // Given:
        final Map<String, Object> newProps = new HashMap<>();
        newProps.put(StreamsConfig.APPLICATION_SERVER_CONFIG, "notused");

        // When:
        sharedKafkaStreamsRuntimeImpl.overrideStreamsProperties(newProps);

        // Then:
        final Map<String, Object> properties = sharedKafkaStreamsRuntimeImpl.streamsProperties;
        assertThat(properties.get(StreamsConfig.APPLICATION_SERVER_CONFIG), equalTo("old"));
        assertThat(properties.size(), equalTo(1));
    }