public void validateAll(final Map<String, Object> properties) {
    final Set<String> propsDenied = Sets.intersection(immutableProps, properties.keySet());
    if (!propsDenied.isEmpty()) {
      throw new KsqlException(String.format("One or more properties overrides set locally are "
          + "prohibited by the KSQL server (use UNSET to reset their default value): %s",
          propsDenied));
    }
  }
@Test
  public void shouldThrowOnKsqlServiceIdProperty() {
    // When:
    final KsqlException e = assertThrows(
        KsqlException.class,
        () -> validator.validateAll(ImmutableMap.of(
            "ksql.service.id", "v1"
        ))
    );

    // Then:
    assertThat(e.getMessage(), containsString(
        "One or more properties overrides set locally are prohibited by the KSQL server "
            + "(use UNSET to reset their default value): [ksql.service.id]"
    ));
  }