diff --git a/src/main/java/io/statnett/k3a/lagexporter/ClusterClient.java b/src/main/java/io/statnett/k3a/lagexporter/ClusterClient.java
index 10fbe10..f49c53f 100644
--- 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 {