Class ConsumerGroupOffsetsManagerImpl
java.lang.Object
io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManagerImpl
- All Implemented Interfaces:
ConsumerGroupOffsetsManager
-
Constructor Summary
ConstructorsConstructorDescriptionConsumerGroupOffsetsManagerImpl(org.apache.kafka.clients.admin.Admin adminClient) -
Method Summary
Modifier and TypeMethodDescriptiongetConsumerGroupOffsets(String consumerGroupId) updateConsumerGroupOffsets(String consumerGroupId, UpdateConsumerGroupOffsetsRequest request)
-
Constructor Details
-
ConsumerGroupOffsetsManagerImpl
@Inject public ConsumerGroupOffsetsManagerImpl(org.apache.kafka.clients.admin.Admin adminClient)
-
-
Method Details
-
getConsumerGroupOffsets
public CompletableFuture<ListConsumerGroupOffsetsResultsData> getConsumerGroupOffsets(String consumerGroupId) - Specified by:
getConsumerGroupOffsetsin interfaceConsumerGroupOffsetsManager
-
updateConsumerGroupOffsets
public CompletableFuture<UpdateConsumerGroupOffsetsResponse> updateConsumerGroupOffsets(@Nonnull String consumerGroupId, @Nonnull UpdateConsumerGroupOffsetsRequest request) - Specified by:
updateConsumerGroupOffsetsin interfaceConsumerGroupOffsetsManager
-