diff --git a/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java b/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
index 05eacc68e3..6acf71e2bb 100644
--- a/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
+++ b/application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
@@ -458,7 +458,7 @@ public class TbRuleEngineQueueConsumerManagerTest {
         verify(consumer2, never()).unsubscribe();
         int msgCount = totalConsumedMsgs.get();
 
-        await().atLeast(4, TimeUnit.SECONDS) // based on topicDeletionDelayInSec
+        await().atLeast(2, TimeUnit.SECONDS) // based on topicDeletionDelayInSec(5) = 5 - ( 3 seconds the code may execute starting consumerManager.delete() call)
                 .atMost(7, TimeUnit.SECONDS)
                 .untilAsserted(() -> {
                     partitions.stream()
@@ -498,7 +498,7 @@ public class TbRuleEngineQueueConsumerManagerTest {
         verify(consumer, never()).unsubscribe();
         int msgCount = totalConsumedMsgs.get();
 
-        await().atLeast(4, TimeUnit.SECONDS)
+        await().atLeast(2, TimeUnit.SECONDS) // based on topicDeletionDelayInSec(5) = 5 - ( 3 seconds the code may execute starting consumerManager.delete() call)
                 .atMost(7, TimeUnit.SECONDS)
                 .untilAsserted(() -> {
                     partitions.stream()