chore(demo-kafka): fix org.apache.kafka.common.errors.TimeoutException

Author: helltractor

demo-kafka/src/test/java/com/helltractor/demo/messaging/MessagingTest.java

@@ -12,13 +12,15 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.context.annotation.Lazy;
+import org.springframework.test.annotation.DirtiesContext;
 
 import java.util.List;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 
 @SpringBootTest(classes = KafkaApplication.class)
+@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
 public class MessagingTest {
 
     final static Logger logger = LoggerFactory.getLogger(MessagingTest.class);
@@ -66,7 +68,7 @@ int getTotalMessages() {
 
     @Test
     void test() throws InterruptedException {
-        for (int i = 0; i < 1000; i++) {
+        for (int i = 0; i < 100; i++) {
             TestMessage testMessage = new TestMessage();
             testMessage.message = "Test-" + i;
             processorOne.sendMessages(testMessage);
@@ -81,6 +83,6 @@ void test() throws InterruptedException {
         }
 
         Thread.sleep(10000);
-        assertEquals(3000, testConsumer.getTotalMessages());
+        assertEquals(300, testConsumer.getTotalMessages());
     }
 }