Class ShareGroupConsumersResource

java.lang.Object

io.confluent.kafkarest.resources.v3.ShareGroupConsumersResource

@Path("/v3/clusters/{clusterId}/share-groups/{groupId}/consumers")
public final class ShareGroupConsumersResource
extends Object

Constructor Summary

Constructors

Constructor	Description
ShareGroupConsumersResource(jakarta.inject.Provider<ShareGroupManager> shareGroupManager, io.confluent.kafkarest.response.CrnFactory crnFactory, io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Summary

Modifier and Type	Method	Description
void	getShareGroupConsumer(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String shareGroupId, String consumerId)
void	listShareGroupAssignments(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String shareGroupId, String consumerId)
void	listShareGroupConsumers(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String shareGroupId)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ShareGroupConsumersResource

@Inject
public ShareGroupConsumersResource(jakarta.inject.Provider<ShareGroupManager> shareGroupManager,
 io.confluent.kafkarest.response.CrnFactory crnFactory,
 io.confluent.kafkarest.response.UrlFactory urlFactory)

Method Details

listShareGroupConsumers

@GET
@Produces("application/json")
@PerformanceMetric("v3.share-group-consumers.list")
public void listShareGroupConsumers(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String shareGroupId)

getShareGroupConsumer

@GET
@Path("/{consumerId}")
@Produces("application/json")
@PerformanceMetric("v3.share-group-consumers.get")
public void getShareGroupConsumer(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String shareGroupId,
 @PathParam("consumerId")
 String consumerId)

listShareGroupAssignments

@GET
@Path("/{consumerId}/assignments")
@Produces("application/json")
@PerformanceMetric("v3.share-group-consumers.assignments.list")
public void listShareGroupAssignments(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("groupId")
 String shareGroupId,
 @PathParam("consumerId")
 String consumerId)