Repository: quarkusio/quarkus
Issue: Kafka Streams Bootstrap Servers Problem

**Describe the bug**
Admin client can't establish the connection to bootstrap server. I'm sure that the host name is correct, when I use it in Kafka Messaging like mp.messaging.connector.smallrye-kafka.bootstrap.servers=my.host.name:9093 there are no problems.

**Expected behavior**
Admin client establishes the connection.

**Actual behavior**
Admin client can't establish the connection.

Kafka Consumer Config logs:
...
bootstrap.servers = [my.host.name/< unresolved >:9093] (Why < unresolved > ??? When I use the same server to mp.messaging, I don't have the < unresolved >)
...
In Console can I see:
...
Connection to node -1 (localhost/127.0.0.1:9093) could not be established. Broker may not be available.
...
ERROR [io.qua.kaf.str.run.KafkaStreamsProducer] (pool-6-thread-1) Failed to get topic names from broker: java.util.concurrent.TimeoutException

**Configuration**
```properties
quarkus.kafka-streams.bootstrap-servers=my.host.name:9093
quarkus.kafka-streams.application-id=...
quarkus.kafka-streams.topics=...

kafka-streams.security.inter.broker.protocol=SSL
kafka-streams.security.protocol=SSL
kafka-streams.ssl.truststore.location=...
kafka-streams.ssl.truststore.password=...
kafka-streams.ssl.keystore.location=...
kafka-streams.ssl.keystore.password=...
kafka-streams.ssl.key.password=...

kafka-streams.cache.max.bytes.buffering=10240
kafka-streams.commit.interval.ms=1000
kafka-streams.metadata.max.age.ms=500
kafka-streams.auto.offset.reset=earliest
kafka-streams.metrics.recording.level=DEBUG

```

**Environment (please complete the following information):**
 - Output of `java -version`: openjdk version "14" 2020-03-17
OpenJDK Runtime Environment (build 14+36-1461)
OpenJDK 64-Bit Server VM (build 14+36-1461, mixed mode, sharing)

 - Quarkus version or git rev: 1.7.0.Final


Changed files:
extensions/consul-config/runtime/src/main/java/io/quarkus/consul/config/runtime/DefaultConsulConfigGateway.java
extensions/jaeger/runtime/src/main/java/io/quarkus/jaeger/runtime/JaegerDeploymentRecorder.java
extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java

diff --git a/extensions/consul-config/runtime/src/main/java/io/quarkus/consul/config/runtime/DefaultConsulConfigGateway.java b/extensions/consul-config/runtime/src/main/java/io/quarkus/consul/config/runtime/DefaultConsulConfigGateway.java
index b2482d48ad8..bf60e6da0aa 100644
--- a/extensions/consul-config/runtime/src/main/java/io/quarkus/consul/config/runtime/DefaultConsulConfigGateway.java
+++ b/extensions/consul-config/runtime/src/main/java/io/quarkus/consul/config/runtime/DefaultConsulConfigGateway.java
@@ -117,7 +117,7 @@ public Optional<Response> getValue(String key) throws IOException {
         }
         try (CloseableHttpClient client = httpClientBuilder.build()) {
             String finalUri = (consulConfig.agent.useHttps ? "https" : "http") + "://"
-                    + consulConfig.agent.hostPort.getHostName() + ":" + consulConfig.agent.hostPort.getPort()
+                    + consulConfig.agent.hostPort.getHostString() + ":" + consulConfig.agent.hostPort.getPort()
                     + "/v1/kv/"
                     + key;
             HttpGet request = new HttpGet(finalUri);
diff --git a/extensions/jaeger/runtime/src/main/java/io/quarkus/jaeger/runtime/JaegerDeploymentRecorder.java b/extensions/jaeger/runtime/src/main/java/io/quarkus/jaeger/runtime/JaegerDeploymentRecorder.java
index 6bb6abb43a1..9be5af77ecc 100644
--- a/extensions/jaeger/runtime/src/main/java/io/quarkus/jaeger/runtime/JaegerDeploymentRecorder.java
+++ b/extensions/jaeger/runtime/src/main/java/io/quarkus/jaeger/runtime/JaegerDeploymentRecorder.java
@@ -60,7 +60,7 @@ private void initTracerConfig(JaegerConfig jaeger) {
         initTracerProperty("JAEGER_AUTH_TOKEN", jaeger.authToken, token -> token);
         initTracerProperty("JAEGER_USER", jaeger.user, user -> user);
         initTracerProperty("JAEGER_PASSWORD", jaeger.password, pw -> pw);
-        initTracerProperty("JAEGER_AGENT_HOST", jaeger.agentHostPort, address -> address.getHostName());
+        initTracerProperty("JAEGER_AGENT_HOST", jaeger.agentHostPort, address -> address.getHostString());
         initTracerProperty("JAEGER_AGENT_PORT", jaeger.agentHostPort, address -> String.valueOf(address.getPort()));
         initTracerProperty("JAEGER_REPORTER_LOG_SPANS", jaeger.reporterLogSpans, log -> log.toString());
         initTracerProperty("JAEGER_REPORTER_MAX_QUEUE_SIZE", jaeger.reporterMaxQueueSize, size -> size.toString());
diff --git a/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java b/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java
index 42cb3cd499b..1037b6dc61f 100644
--- a/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java
+++ b/extensions/kafka-streams/runtime/src/main/java/io/quarkus/kafka/streams/runtime/KafkaStreamsProducer.java
@@ -254,10 +254,14 @@ private static <T> void setProperty(Optional<T> property, Properties properties,
 
     private static String asString(List<InetSocketAddress> addresses) {
         return addresses.stream()
-                .map(InetSocketAddress::toString)
+                .map(KafkaStreamsProducer::toHostPort)
                 .collect(Collectors.joining(","));
     }
 
+    private static String toHostPort(InetSocketAddress inetSocketAddress) {
+        return inetSocketAddress.getHostString() + ":" + inetSocketAddress.getPort();
+    }
+
     private static void waitForTopicsToBeCreated(Admin adminClient, Collection<String> topicsToAwait)
             throws InterruptedException {
         Set<String> lastMissingTopics = null;