From 045ba2ccebfe9abf32f25fc2731dcce564900b24 Mon Sep 17 00:00:00 2001 From: mooncw Date: Wed, 31 Jan 2024 12:14:03 +0900 Subject: [PATCH] =?UTF-8?q?[test]=20=EC=B9=B4=ED=94=84=EC=B9=B4=20?= =?UTF-8?q?=ED=85=8C=EC=8A=A4=ED=8A=B8=20=EC=B6=94=EA=B0=80=202=EC=B0=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kernelsquare/domain/coffeechat/kafka/KafkaTest.java | 3 ++- 1 file changed, 2 insertions(+), 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 index 13178de..a3a3371 100644 --- 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);