Merge branch 'fix/type-casting-errors' into feature/reset-connector-offsets

Author: Dugong42

api/src/main/java/io/kafbat/ui/service/TopicsService.java

@@ -13,6 +13,7 @@
 import io.kafbat.ui.model.InternalLogDirStats;
 import io.kafbat.ui.model.InternalPartition;
 import io.kafbat.ui.model.InternalPartitionsOffsets;
+import io.kafbat.ui.model.InternalPartitionsOffsets.Offsets;
 import io.kafbat.ui.model.InternalReplica;
 import io.kafbat.ui.model.InternalTopic;
 import io.kafbat.ui.model.InternalTopicConfig;
@@ -143,14 +144,12 @@ private Mono<InternalPartitionsOffsets> getPartitionOffsets(Map<String, TopicDes
     var descriptions = descriptionsMap.values();
     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)))
+            (earliest, latest) -> (Map<TopicPartition, Offsets>) 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);
   }
 

api/src/main/java/io/kafbat/ui/service/audit/AuditService.java

@@ -181,11 +181,11 @@ private Mono<AuthenticatedUser> extractUser(Signal<?> sig) {
 
     return sig.getContextView().<Mono<SecurityContext>>get(key)
         .map(context -> context.getAuthentication().getPrincipal())
-        .map(AuditService::extractUser)
+        .map(AuditService::extractUserFromObject)
         .switchIfEmpty(Mono.just(UNKNOWN_USER));
   }
 
-  private static AuthenticatedUser extractUser(Object principal) {
+  private static AuthenticatedUser extractUserFromObject(Object principal) {
     if (principal instanceof UserDetails u) {
       return new AuthenticatedUser(u.getUsername(), Set.of());
     } else if (principal instanceof AuthenticatedPrincipal p) {