Class ConsumerGroupOffsetsResource

java.lang.Object

io.confluent.kafkarest.resources.v3.ConsumerGroupOffsetsResource

@Path("/v3/clusters/{clusterId}/internal/consumer-groups/{consumerGroupId}/offsets")
public final class ConsumerGroupOffsetsResource
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ALTER_OFFSETS_INVALID_CONSUMER_GROUP_STATE_ERROR_TMPL

Constructor Summary

Constructors

Constructor	Description
ConsumerGroupOffsetsResource(jakarta.inject.Provider<ConsumerGroupOffsetsManager> consumerGroupOffsetsManager, jakarta.inject.Provider<io.confluent.kafkarest.controllers.ConsumerGroupManager> consumerGroupManager)

Method Summary

Modifier and Type	Method	Description
void	getConsumerGroupOffsets(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String consumerGroupId)
void	updateConsumerGroupOffset(jakarta.ws.rs.container.AsyncResponse asyncResponse, String clusterId, String consumerGroupId, @Valid UpdateConsumerGroupOffsetsRequest request)

Methods inherited from class java.lang.Object

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

Field Details

ALTER_OFFSETS_INVALID_CONSUMER_GROUP_STATE_ERROR_TMPL

public static final String ALTER_OFFSETS_INVALID_CONSUMER_GROUP_STATE_ERROR_TMPL

See Also:

• Constant Field Values

Constructor Details

ConsumerGroupOffsetsResource

@Inject
public ConsumerGroupOffsetsResource(jakarta.inject.Provider<ConsumerGroupOffsetsManager> consumerGroupOffsetsManager,
 jakarta.inject.Provider<io.confluent.kafkarest.controllers.ConsumerGroupManager> consumerGroupManager)

Method Details

getConsumerGroupOffsets

@GET
@Consumes("application/json")
@Produces("application/json")
@PerformanceMetric("api.v3.consumer-groups.offsets.get")
public void getConsumerGroupOffsets(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("consumerGroupId")
 String consumerGroupId)

updateConsumerGroupOffset

@PATCH
@Consumes("application/json")
@Produces("application/json")
@PerformanceMetric("api.v3.consumer-groups.offsets.patch")
public void updateConsumerGroupOffset(@Suspended
 jakarta.ws.rs.container.AsyncResponse asyncResponse,
 @PathParam("clusterId")
 String clusterId,
 @PathParam("consumerGroupId")
 String consumerGroupId,
 @Valid
 @Valid UpdateConsumerGroupOffsetsRequest request)