iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BAEL-7374 - Renamed to live test

Browse Source
This commit is contained in:
Amol Gote 2024-02-13 09:15:00 -05:00
parent 3b4d456e3a
commit 36f3e32ff6
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
spring-kafka-3/src/test/java/com/baeldung/spring/kafka/startstopconsumer/StartStopConsumerUnitTest.java → spring-kafka-3/src/test/java/com/baeldung/spring/kafka/startstopconsumer/StartStopConsumerLiveTest.java
View File

@ -33,13 +33,14 @@ import java.util.*;
import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future; import java.util.concurrent.Future;
// This live test needs a Docker Daemon running so that a kafka container can be created
@Testcontainers @Testcontainers
@SpringBootTest(classes = StartStopConsumerApplication.class) @SpringBootTest(classes = StartStopConsumerApplication.class)
public class StartStopConsumerUnitTest { public class StartStopConsumerLiveTest {
private static KafkaProducer<Long, UserEvent> producer; private static KafkaProducer<Long, UserEvent> producer;
private static final Logger logger = LoggerFactory.getLogger(StartStopConsumerUnitTest.class); private static final Logger logger = LoggerFactory.getLogger(StartStopConsumerLiveTest.class);
@Container @Container
private static KafkaContainer KAFKA_CONTAINER = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:latest")); private static KafkaContainer KAFKA_CONTAINER = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:latest"));