diff --git a/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java b/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
index a25f74a5b1..e696192a43 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
@@ -63,12 +63,12 @@ public class TbQueueConsumerTask {
 
     public void subscribe(Set<TopicPartitionInfo> partitions) {
         log.trace("[{}] Subscribing to partitions: {}", key, partitions);
-        consumer.subscribe(partitions);
+        getConsumer().subscribe(partitions);
     }
 
     public void initiateStop() {
         log.debug("[{}] Initiating stop", key);
-        consumer.stop();
+        getConsumer().stop();
     }
 
     public void awaitCompletion() {