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

[JAVA-33808] change spring-kafka-2 integration test to live test (#16468)

This commit is contained in:
Harry9656 2024-04-23 07:58:35 +02:00 committed by GitHub
parent b2efaa0112
commit 26ce8f7bae
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
spring-kafka-2/src/test/java/com/baeldung/spring/kafka/managingkafkaconsumergroups/ManagingConsumerGroupsIntegrationTest.java → spring-kafka-2/src/test/java/com/baeldung/spring/kafka/managingkafkaconsumergroups/ManagingConsumerGroupsLiveTest.java
View File

@ -2,7 +2,6 @@ package com.baeldung.spring.kafka.managingkafkaconsumergroups;
import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertEquals;
import java.time.Duration;
import java.util.Objects; import java.util.Objects;
import java.util.Set; import java.util.Set;
@ -26,7 +25,7 @@ import lombok.extern.slf4j.Slf4j;
@DirtiesContext(classMode = ClassMode.BEFORE_CLASS) @DirtiesContext(classMode = ClassMode.BEFORE_CLASS)
@ActiveProfiles("managed") @ActiveProfiles("managed")
@Slf4j @Slf4j
class ManagingConsumerGroupsIntegrationTest { class ManagingConsumerGroupsLiveTest {
private static final String CONSUMER_1_IDENTIFIER = "org.springframework.kafka.KafkaListenerEndpointContainer#1"; private static final String CONSUMER_1_IDENTIFIER = "org.springframework.kafka.KafkaListenerEndpointContainer#1";
private static final int TOTAL_PRODUCED_MESSAGES = 5000; private static final int TOTAL_PRODUCED_MESSAGES = 5000;