public URL getInterNodeListener(
      final Function<URL, Integer> portResolver
  ) {
    return getInterNodeListener(portResolver, LOGGER);
  }
@Test
  public void shouldThrowIfOnGetInterNodeListenerIfInternalListenerSetToUnresolvableHost() {
    // Given:
    final URL expected = url("https://unresolvable_host:12345");

    final KsqlRestConfig config = new KsqlRestConfig(ImmutableMap.<String, Object>builder()
        .put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092")
        .put(INTERNAL_LISTENER_CONFIG, expected.toString())
        .build()
    );

    // When:
    final Exception e = assertThrows(
        ConfigException.class,
        () -> config.getInterNodeListener(portResolver, logger)
    );

    // Then:
    assertThat(e.getMessage(), containsString("Invalid value "
        + "https://unresolvable_host:12345 for configuration "
        + INTERNAL_LISTENER_CONFIG
        + ": Could not resolve internal host"));
  }