From 915437809fe9f0619765296f06ef9e6d40e99df8 Mon Sep 17 00:00:00 2001
From: Wojciech Sowa <wojciech.a.sowa@allegro.pl>
Date: Mon, 19 Jun 2023 16:10:02 +0200
Subject: [PATCH] Fix pr

---
 .../management/infrastructure/kafka/MultiDCAwareService.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hermes-management/src/main/java/pl/allegro/tech/hermes/management/infrastructure/kafka/MultiDCAwareService.java b/hermes-management/src/main/java/pl/allegro/tech/hermes/management/infrastructure/kafka/MultiDCAwareService.java
index 63ee2d0ea8..f8cdc9367f 100644
--- a/hermes-management/src/main/java/pl/allegro/tech/hermes/management/infrastructure/kafka/MultiDCAwareService.java
+++ b/hermes-management/src/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));
     }
 }