diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/ConsumerGroupsController.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/ConsumerGroupsController.java index c0d4d0296c..4bba879b01 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/ConsumerGroupsController.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/ConsumerGroupsController.java @@ -53,17 +53,6 @@ public class ConsumerGroupsController extends AbstractController implements Cons .map(ResponseEntity::ok); } - - @Override - public Mono>> getConsumerGroups(String clusterName, - ServerWebExchange exchange) { - return consumerGroupService.getAllConsumerGroups(getCluster(clusterName)) - .map(Flux::fromIterable) - .map(f -> f.map(ConsumerGroupMapper::toDto)) - .map(ResponseEntity::ok) - .switchIfEmpty(Mono.just(ResponseEntity.notFound().build())); - } - @Override public Mono>> getTopicConsumerGroups( String clusterName, String topicName, ServerWebExchange exchange) { diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ConsumerGroupService.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ConsumerGroupService.java index a82224ed27..ee9a9d8a6a 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ConsumerGroupService.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/ConsumerGroupService.java @@ -64,13 +64,6 @@ public class ConsumerGroupService { }); } - @Deprecated // need to migrate to pagination - public Mono> getAllConsumerGroups(KafkaCluster cluster) { - return adminClientService.get(cluster) - .flatMap(ac -> describeConsumerGroups(ac, null) - .flatMap(descriptions -> getConsumerGroups(ac, descriptions))); - } - public Mono> getConsumerGroupsForTopic(KafkaCluster cluster, String topic) { return adminClientService.get(cluster) diff --git a/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml b/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml index 55ea795f03..c4765fb220 100644 --- a/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml +++ b/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml @@ -862,28 +862,6 @@ paths: 200: description: OK - /api/clusters/{clusterName}/consumer-groups: - get: - tags: - - Consumer Groups - summary: get all ConsumerGroups - operationId: getConsumerGroups - parameters: - - name: clusterName - in: path - required: true - schema: - type: string - responses: - 200: - description: OK - content: - application/json: - schema: - type: array - items: - $ref: '#/components/schemas/ConsumerGroup' - /api/clusters/{clusterName}/consumer-groups/{id}/offsets: post: tags: