Increase the UserKafkaConsumerTest timeout

kasramp · Jan 2, 2024 · 62e5bd0 · 62e5bd0
1 parent 08e7312
commit 62e5bd0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/com/madadipouya/springkafkatest/kafka/consumer/UserKafkaConsumerTest.java b/src/test/java/com/madadipouya/springkafkatest/kafka/consumer/UserKafkaConsumerTest.java
@@ -90,7 +90,7 @@ void testLogKafkaMessages() throws JsonProcessingException {
         producer.flush();
 
         // Read the message and assert its properties
-        verify(userKafkaConsumer, timeout(5000).times(1))
+        verify(userKafkaConsumer, timeout(10000).times(1))
                 .logKafkaMessages(userArgumentCaptor.capture(), topicArgumentCaptor.capture(),
                         partitionArgumentCaptor.capture(), offsetArgumentCaptor.capture());