From 5e3ff6fe20d24fbdb4d68d4e0bc452836a771997 Mon Sep 17 00:00:00 2001 From: Sergey Matvienko Date: Wed, 22 May 2024 09:02:01 +0200 Subject: [PATCH] minor cleanup --- .../java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java | 1 - 1 file changed, 1 deletion(-) 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)); }