diff --git a/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManager.java b/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManager.java
index c147836dab..879da5afc6 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManager.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManager.java
@@ -73,8 +73,8 @@ public class TbRuleEngineQueueConsumerManager extends MainQueueConsumerManager<T
                                             ScheduledExecutorService scheduler,
                                             ExecutorService taskExecutor) {
         super(queueKey, null, null,
-                (queueConfig, topicPartitionInfo) -> {
-                    Integer partitionId = topicPartitionInfo.getPartition().orElse(-1);
+                (queueConfig, tpi) -> {
+                    Integer partitionId = tpi != null ? tpi.getPartition().orElse(-1) : null;
                     return ctx.getQueueFactory().createToRuleEngineMsgConsumer(queueConfig, partitionId);
                 },
                 consumerExecutor, scheduler, taskExecutor, null);