Skip to content

Commit

Permalink
docs: fix typos in api summaries (#2074)
Browse files Browse the repository at this point in the history
  • Loading branch information
mikaelol authored Feb 16, 2025
1 parent bb8b066 commit 96f20cd
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 9 deletions.
2 changes: 1 addition & 1 deletion src/main/java/org/akhq/controllers/AkhqController.java
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public class AkhqController extends AbstractController {

@HasAnyPermission()
@Get("api/cluster")
@Operation(tags = {"AKHQ"}, summary = "Get all cluster for current instance")
@Operation(tags = {"AKHQ"}, summary = "Get all clusters for current instance")
public List<ClusterDefinition> list() {
// Get all the clusters the logged user can access resources
List<String> clusters = this.getUserGroups().stream()
Expand Down
8 changes: 4 additions & 4 deletions src/main/java/org/akhq/controllers/GroupController.java
Original file line number Diff line number Diff line change
Expand Up @@ -79,23 +79,23 @@ public ConsumerGroup home(String cluster, String groupName) throws ExecutionExce
}

@Get("{groupName}/offsets")
@Operation(tags = {"consumer group"}, summary = "Retrieve a consumer group offsets")
@Operation(tags = {"consumer group"}, summary = "Retrieve consumer group offsets")
public List<TopicPartition.ConsumerGroupOffset> offsets(String cluster, String groupName) throws ExecutionException, InterruptedException {
checkIfClusterAndResourceAllowed(cluster, groupName);

return this.consumerGroupRepository.findByName(cluster, groupName, buildUserBasedResourceFilters(cluster)).getOffsets();
}

@Get("{groupName}/members")
@Operation(tags = {"consumer group"}, summary = "Retrieve a consumer group members")
@Operation(tags = {"consumer group"}, summary = "Retrieve consumer group members")
public List<Consumer> members(String cluster, String groupName) throws ExecutionException, InterruptedException {
checkIfClusterAndResourceAllowed(cluster, groupName);

return this.consumerGroupRepository.findByName(cluster, groupName, buildUserBasedResourceFilters(cluster)).getMembers();
}

@Get("{groupName}/acls")
@Operation(tags = {"consumer group"}, summary = "Retrieve a consumer group acls")
@Operation(tags = {"consumer group"}, summary = "Retrieve consumer group acls")
public List<AccessControl> acls(String cluster, String groupName) throws ExecutionException, InterruptedException {
checkIfClusterAndResourceAllowed(cluster, groupName);

Expand Down Expand Up @@ -178,7 +178,7 @@ public HttpResponse<?> delete(String cluster, String groupName) throws Execution

@AKHQSecured(resource = Role.Resource.CONSUMER_GROUP, action = Role.Action.DELETE_OFFSET)
@Delete("{groupName}/topic/{topicName}")
@Operation(tags = {"consumer group"}, summary = "Delete group offsets of given topic")
@Operation(tags = {"consumer group"}, summary = "Delete consumer group offsets for the given topic")
public HttpResponse<?> deleteConsumerGroupOffsets(String cluster, String groupName, String topicName) throws ExecutionException {
checkIfClusterAndResourceAllowed(cluster, groupName);

Expand Down
4 changes: 2 additions & 2 deletions src/main/java/org/akhq/controllers/NodeController.java
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public static class NodePartition {
}

@Get("api/{cluster}/node/partitions")
@Operation(tags = {"topic"}, summary = "partition counts")
@Operation(tags = {"topic"}, summary = "Partition counts")
public List<NodePartition> nodePartitions(String cluster) throws ExecutionException, InterruptedException {
checkIfClusterAllowed(cluster);

Expand Down Expand Up @@ -93,7 +93,7 @@ public Cluster list(String cluster) throws ExecutionException, InterruptedExcept
}

@Get("api/{cluster}/node/{nodeId}")
@Operation(tags = {"node"}, summary = "Retrieve a nodes")
@Operation(tags = {"node"}, summary = "Retrieve a node")
public Node node(String cluster, Integer nodeId) throws ExecutionException, InterruptedException {
checkIfClusterAndResourceAllowed(cluster, nodeId.toString());

Expand Down
4 changes: 2 additions & 2 deletions src/main/java/org/akhq/controllers/SchemaController.java
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public List<String> listAll(


@Get("api/{cluster}/schema")
@Operation(tags = {"schema registry"}, summary = "List all schemas")
@Operation(tags = {"schema registry"}, summary = "List all schemas paginated")
public ResultPagedList<Schema> list(
HttpRequest<?> request,
String cluster,
Expand All @@ -79,7 +79,7 @@ public ResultPagedList<Schema> list(
}

@Get("api/{cluster}/schema/topic/{topic}")
@Operation(tags = {"schema registry"}, summary = "List all schemas prefered schemas for this topic")
@Operation(tags = {"schema registry"}, summary = "List all preferred schemas for a topic")
public TopicSchema listSchemaForTopic(
HttpRequest<?> request,
String cluster,
Expand Down

0 comments on commit 96f20cd

Please sign in to comment.