File tree Expand file tree Collapse file tree 1 file changed +7
-6
lines changed
api/src/main/java/io/kafbat/ui/service Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -209,12 +209,13 @@ private Mono<List<ConsumerGroupDescription>> describeConsumerGroups(ReactiveAdmi
209209 }
210210
211211
212- private Mono <List <ConsumerGroupDescription >> loadDescriptionsByInternalConsumerGroups (ReactiveAdminClient ac ,
213- List <ConsumerGroupListing > groups ,
214- Comparator <GroupWithDescr > comparator ,
215- int pageNum ,
216- int perPage ,
217- SortOrderDTO sortOrderDto ) {
212+ private Mono <List <ConsumerGroupDescription >> loadDescriptionsByInternalConsumerGroups (
213+ ReactiveAdminClient ac ,
214+ List <ConsumerGroupListing > groups ,
215+ Comparator <GroupWithDescr > comparator ,
216+ int pageNum ,
217+ int perPage ,
218+ SortOrderDTO sortOrderDto ) {
218219 var groupNames = groups .stream ().map (ConsumerGroupListing ::groupId ).toList ();
219220
220221 return ac .describeConsumerGroups (groupNames )
You can’t perform that action at this time.
0 commit comments