diff --git a/apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationIntegrationTest.java b/apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationLiveTest.java similarity index 91% rename from apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationIntegrationTest.java rename to apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationLiveTest.java index d79f6af7c1..3f89131464 100644 --- a/apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationIntegrationTest.java +++ b/apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationLiveTest.java @@ -12,8 +12,10 @@ import java.util.Properties; 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 index 67fff12f5e..14d76cb6ef 100644 --- 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 java.util.concurrent.atomic.AtomicReference; 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 index 88de6101dc..e199042682 100644 --- 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.consumer.ConsumerConfig.BOOTSTRAP_SERVERS 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";