diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java b/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java
index b818cd1234..9c8f63594b 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java
@@ -116,7 +116,6 @@ public class TbKafkaAdmin implements TbQueueAdmin {
     }
 
     public CreateTopicsResult createTopic(NewTopic topic) {
-        client.listConsumerGroupOffsets("id1");
         return client.createTopics(Collections.singletonList(topic));
     }