Fix checkstyle

kafbat · Oct 9, 2024 · 23cd882 · 23cd882
1 parent cf7b2e5
commit 23cd882
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 7 deletions.
diff --git a/api/src/main/java/io/kafbat/ui/controller/ConsumerGroupsController.java b/api/src/main/java/io/kafbat/ui/controller/ConsumerGroupsController.java
@@ -60,7 +60,9 @@ public Mono<ResponseEntity<Void>> deleteConsumerGroup(String clusterName,
   }
 
   @Override
-  public Mono<ResponseEntity<Void>> deleteConsumerGroupOffsets(String clusterName, String groupId, String topicName,
+  public Mono<ResponseEntity<Void>> deleteConsumerGroupOffsets(String clusterName,
+                                                               String groupId,
+                                                               String topicName,
                                                                ServerWebExchange exchange) {
     var context = AccessContext.builder()
         .cluster(clusterName)

diff --git a/api/src/main/java/io/kafbat/ui/service/ConsumerGroupService.java b/api/src/main/java/io/kafbat/ui/service/ConsumerGroupService.java
@@ -210,11 +210,11 @@ private Mono<List<ConsumerGroupDescription>> describeConsumerGroups(ReactiveAdmi
 
 
   private Mono<List<ConsumerGroupDescription>> loadDescriptionsByInternalConsumerGroups(ReactiveAdminClient ac,
-                                                                                  List<ConsumerGroupListing> groups,
-                                                                                  Comparator<GroupWithDescr> comparator,
-                                                                                  int pageNum,
-                                                                                  int perPage,
-                                                                                  SortOrderDTO sortOrderDto) {
+                                                                                        List<ConsumerGroupListing> groups,
+                                                                                        Comparator<GroupWithDescr> comparator,
+                                                                                        int pageNum,
+                                                                                        int perPage,
+                                                                                        SortOrderDTO sortOrderDto) {
     var groupNames = groups.stream().map(ConsumerGroupListing::groupId).toList();
 
     return ac.describeConsumerGroups(groupNames)
@@ -248,7 +248,7 @@ public Mono<Void> deleteConsumerGroupById(KafkaCluster cluster,
   }
 
   public Mono<Void> deleteConsumerGroupOffset(KafkaCluster cluster,
-                                            String groupId,
+                                              String groupId,
                                               String topicName) {
     return adminClientService.get(cluster)
         .flatMap(adminClient -> adminClient.deleteConsumerGroupOffsets(groupId, topicName));