fix: use getAdmin instead of admin to ensure object is created (#220)

statnett · Sep 29, 2024 · 66a3636 · 66a3636
1 parent 7fd821d
commit 66a3636
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/statnett/k3a/lagexporter/ClusterClient.java b/src/main/java/io/statnett/k3a/lagexporter/ClusterClient.java
@@ -83,7 +83,7 @@ public Map<String, Map<TopicPartition, OffsetAndMetadata>> consumerGroupOffsets(
         try {
             final Map<String, ListConsumerGroupOffsetsSpec> groupSpecs = consumerGroupIds.stream()
                 .collect(Collectors.toMap(identity(), s -> new ListConsumerGroupOffsetsSpec().topicPartitions(null)));
-            return admin.listConsumerGroupOffsets(groupSpecs).all().get();
+            return getAdmin().listConsumerGroupOffsets(groupSpecs).all().get();
         } catch (final Exception e) {
             throw new RuntimeException(e);
         } finally {