[test] 카프카 테스트 추가 2차

KernelSquare · Jan 31, 2024 · 045ba2c · 045ba2c
1 parent 3d9c058
commit 045ba2c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/test/java/com/kernel360/kernelsquare/domain/coffeechat/kafka/KafkaTest.java b/src/test/java/com/kernel360/kernelsquare/domain/coffeechat/kafka/KafkaTest.java
@@ -34,7 +34,8 @@ void TestSendAndReceive() throws InterruptedException {
 
         //when
         producer.produce(sendMessage);
-        consumer.getLatch().await(10, TimeUnit.SECONDS);
+        consumer.getLatch().await(30, TimeUnit.SECONDS);
+
 
         //then
         assertThat(consumer.getLatch().getCount()).isEqualTo(0L);