diff --git a/api/src/main/java/io/kafbat/ui/service/TopicsService.java b/api/src/main/java/io/kafbat/ui/service/TopicsService.java
index 7b5ae20fb..015a86838 100644
--- a/api/src/main/java/io/kafbat/ui/service/TopicsService.java
+++ b/api/src/main/java/io/kafbat/ui/service/TopicsService.java
@@ -144,13 +144,13 @@ private Mono<InternalPartitionsOffsets> getPartitionOffsets(Map<String, TopicDes
     return ac.listOffsets(descriptions, OffsetSpec.earliest())
         .zipWith(ac.listOffsets(descriptions, OffsetSpec.latest()),
             (earliest, latest) ->
-            Sets.intersection(earliest.keySet(), latest.keySet())
-                .stream()
-                .map(tp ->
-                    Map.entry(tp,
-                        new InternalPartitionsOffsets.Offsets(
-                            earliest.get(tp), latest.get(tp))))
-                .collect(toMap(Map.Entry::getKey, Map.Entry::getValue)))
+                Sets.intersection(earliest.keySet(), latest.keySet())
+                    .stream()
+                    .map(tp ->
+                        Map.entry(tp,
+                            new InternalPartitionsOffsets.Offsets(
+                                earliest.get(tp), latest.get(tp))))
+                    .collect(toMap(Map.Entry::getKey, Map.Entry::getValue)))
         .map(InternalPartitionsOffsets::new);
   }