|
13 | 13 | import io.kafbat.ui.model.InternalLogDirStats; |
14 | 14 | import io.kafbat.ui.model.InternalPartition; |
15 | 15 | import io.kafbat.ui.model.InternalPartitionsOffsets; |
16 | | -import io.kafbat.ui.model.InternalPartitionsOffsets.Offsets; |
17 | 16 | import io.kafbat.ui.model.InternalReplica; |
18 | 17 | import io.kafbat.ui.model.InternalTopic; |
19 | 18 | import io.kafbat.ui.model.InternalTopicConfig; |
@@ -144,11 +143,13 @@ private Mono<InternalPartitionsOffsets> getPartitionOffsets(Map<String, TopicDes |
144 | 143 | var descriptions = descriptionsMap.values(); |
145 | 144 | return ac.listOffsets(descriptions, OffsetSpec.earliest()) |
146 | 145 | .zipWith(ac.listOffsets(descriptions, OffsetSpec.latest()), |
147 | | - (earliest, latest) -> (Map<TopicPartition, Offsets>) Sets.intersection(earliest.keySet(), latest.keySet()) |
| 146 | + (earliest, latest) -> |
| 147 | + Sets.intersection(earliest.keySet(), latest.keySet()) |
148 | 148 | .stream() |
149 | | - .map(tp -> Map.entry(tp, |
150 | | - new InternalPartitionsOffsets.Offsets( |
151 | | - earliest.get(tp), latest.get(tp)))) |
| 149 | + .map(tp -> |
| 150 | + Map.entry(tp, |
| 151 | + new InternalPartitionsOffsets.Offsets( |
| 152 | + earliest.get(tp), latest.get(tp)))) |
152 | 153 | .collect(toMap(Map.Entry::getKey, Map.Entry::getValue))) |
153 | 154 | .map(InternalPartitionsOffsets::new); |
154 | 155 | } |
|
0 commit comments