JAVA-7309: Take a look into failing apache-kafka tests

floison51 · Oct 6, 2021 · 682f036 · 682f036
1 parent 375803d
commit 682f036
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 1 deletion.
diff --git a/...KafkaTopicApplicationIntegrationTest.java → .../admin/KafkaTopicApplicationLiveTest.java b/...KafkaTopicApplicationIntegrationTest.java → .../admin/KafkaTopicApplicationLiveTest.java
@@ -12,8 +12,10 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+// This live test needs a running Docker instance so that a kafka container can be created 
+
 @Testcontainers
-class KafkaTopicApplicationIntegrationTest {
+class KafkaTopicApplicationLiveTest {
 
     @Container
     private static final KafkaContainer KAFKA_CONTAINER = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"));

diff --git a/apache-kafka/src/test/java/com/baeldung/kafka/serdes/KafkaSerDesLiveTest.java b/apache-kafka/src/test/java/com/baeldung/kafka/serdes/KafkaSerDesLiveTest.java
@@ -20,6 +20,8 @@
 
 import static org.junit.Assert.assertEquals;
 
+// This live test needs a Docker instance running so that kafka container can be created
+
 public class KafkaSerDesLiveTest {
     private static final String CONSUMER_APP_ID = "consumer_id";
     private static final String CONSUMER_GROUP_ID = "group_id";

diff --git a/apache-kafka/src/test/java/com/baeldung/kafka/streamsvsconsumer/KafkaStreamsLiveTest.java b/apache-kafka/src/test/java/com/baeldung/kafka/streamsvsconsumer/KafkaStreamsLiveTest.java
@@ -44,6 +44,8 @@
 import static org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG;
 import static org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG;
 
+// This live test needs a Docker instance running so that kafka container can be created
+
 public class KafkaStreamsLiveTest {
     private final String LEFT_TOPIC = "left-stream-topic";
     private final String RIGHT_TOPIC = "right-stream-topic";