Try docker container test instead of inmemory

quarkus-kafaka-homework/kafka-producer/src/test/java/me/jochrist/kafka/ProducerTest.java

@@ -16,29 +16,22 @@ import javax.enterprise.inject.Any;
 import javax.inject.Inject;
 import io.quarkus.test.common.QuarkusTestResource;
 
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.WebTarget;
+import javax.ws.rs.sse.SseEventSource;
 
 @QuarkusTest
 @QuarkusTestResource(KafkaResource.class)
 public class ProducerTest {
 
-    @BeforeAll
-    public static void switchMyChannels() {
-        InMemoryConnector.switchIncomingChannelsToInMemory("timestamp");
-        InMemoryConnector.switchIncomingChannelsToInMemory("user-message");
-        InMemoryConnector.switchOutgoingChannelsToInMemory("timestamp");
-        InMemoryConnector.switchOutgoingChannelsToInMemory("user-message");
-    }
-
-    @AfterAll
-    public static void revertMyChannels() {
-        InMemoryConnector.clear();
-    }
-
 
     //See https://developer.mozilla.org/en-US/docs/Web/HTTP/Status/204
     //As we dont need to return anything 204 is still a success
     @Test
     public void testMessage() {
+
+        SseEventSource source = SseEventSource.target(target).build();
         given()
           .when().get("/kafka/message/test")
           .then()

quarkus-kafaka-homework/pom.xml

@@ -20,7 +20,7 @@
                 <activeByDefault>false</activeByDefault>
             </activation>
             <modules>
-                <module>docker-resources</module>
+                <module>resources</module>
             </modules>
         </profile>
     </profiles>
@@ -42,7 +42,7 @@
      <quarkus.platform.version>1.8.1.Final</quarkus.platform.version>
      <surefire-plugin.version>3.0.0-M5</surefire-plugin.version>
      <quarkus.container-image.builder>s2i</quarkus.container-image.builder>
-      <testcontainers.version>1.14.1</testcontainers.version>
+      <testcontainers.version>1.14.3</testcontainers.version>
  </properties>