Fix pr

allegro · Jun 19, 2023 · 9154378 · 9154378
1 parent 1715077
commit 9154378
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/pl/allegro/tech/hermes/management/infrastructure/kafka/MultiDCAwareService.java b/...main/java/pl/allegro/tech/hermes/management/infrastructure/kafka/MultiDCAwareService.java
@@ -148,6 +148,6 @@ public List<ConsumerGroup> describeConsumerGroups(Topic topic, String subscripti
     }
 
     public void moveOffsetsToTheEnd(Topic topic, SubscriptionName subscription) {
-        clusters.forEach(c -> c.moveOffsetsToTheEnd(topic, subscription));
+        clustersProvider.getClusters().forEach(c -> c.moveOffsetsToTheEnd(topic, subscription));
     }
 }