public Map<String, Object> getKsqlStreamConfigProps(final String applicationId) {
    final Map<String, Object> map = new HashMap<>(getKsqlStreamConfigProps());
    map.put(
        MetricCollectors.RESOURCE_LABEL_PREFIX
            + StreamsConfig.APPLICATION_ID_CONFIG,
        applicationId
    );

    // Streams client metrics aren't used in Confluent deployment
    possiblyConfigureConfluentTelemetry(map);
    return Collections.unmodifiableMap(map);
  }
@Test
  public void shouldOverrideStreamsConfigProperties() {
    Map<String, Object> originals = new HashMap<>();
    originals.put(KsqlConfig.KSQL_STREAMS_PREFIX + SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG,
            "kafka.jks");
    originals.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG,
            "https.jks");

    final KsqlConfig ksqlConfig = new KsqlConfig(originals);

    assertThat(ksqlConfig.getKsqlStreamConfigProps().
            get(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG), equalTo("kafka.jks"));

  }