From 45cd9af1637167155125789cbe7bfefbc957d8ad Mon Sep 17 00:00:00 2001
From: IrynaMatveieva <irina.m2004@icloud.com>
Date: Fri, 11 Apr 2025 10:02:39 +0300
Subject: [PATCH] fixed ruel engine consumer

---
 .../queue/ruleengine/TbRuleEngineQueueConsumerManager.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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);