diff --git a/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/ReactiveMessagingKafkaIT.java b/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/ReactiveMessagingKafkaIT.java
index 04cc5973f7..829be6aa6b 100644
--- a/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/ReactiveMessagingKafkaIT.java
+++ b/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/ReactiveMessagingKafkaIT.java
@@ -121,8 +121,8 @@ private boolean checkResponse(CloseableHttpResponse response, boolean fail) thro
             return false;
         }
 
-        Assert.assertNotEquals("Expected to find 'Hello' on line 0 of:\n" + lines, -1, lines.get(0).indexOf("Hello"));
-        Assert.assertNotEquals("Expected to find 'Kafka' on line 1 of:\n" + lines, -1, lines.get(1).indexOf("Kafka"));
+        Assert.assertNotEquals("Expected to find 'Hello' on line 0 of:\n" + lines, -1, lines.get(1).indexOf("Hello"));
+        Assert.assertNotEquals("Expected to find 'Kafka' on line 1 of:\n" + lines, -1, lines.get(2).indexOf("Kafka"));
         for (int i = 2; i < lines.size(); i++) {
             Assert.assertNotEquals(
                     "Expected to find 'Hello' or 'Kafka' on line " + i +
diff --git a/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/TestUtils.java b/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/TestUtils.java
index a58bfa7ef0..01ec086b37 100644
--- a/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/TestUtils.java
+++ b/microprofile-reactive-messaging-kafka/src/test/java/org/wildfly/quickstarts/microprofile/reactive/messaging/test/TestUtils.java
@@ -1,7 +1,8 @@
 package org.wildfly.quickstarts.microprofile.reactive.messaging.test;
 
 public class TestUtils {
-    static final String DEFAULT_SERVER_HOST = "http://localhost:8080/microprofile-reactive-messaging-kafka/rest";
+    static final String DEFAULT_SERVER_HOST = "http://localhost:8080/microprofile-reactive-messaging-kafka";
+    static final String API_PATH = "/rest";
 
     static String getServerHost() {
         String serverHost = System.getenv("SERVER_HOST");
@@ -11,6 +12,6 @@ static String getServerHost() {
         if (serverHost == null) {
             serverHost = DEFAULT_SERVER_HOST;
         }
-        return serverHost;
+        return serverHost + API_PATH;
     }
 }