Class ConsumerGroupOffsetsManagerImpl

java.lang.Object

io.confluent.kafkarest.controllers.ConsumerGroupOffsetsManagerImpl

All Implemented Interfaces:

ConsumerGroupOffsetsManager

public class ConsumerGroupOffsetsManagerImpl
extends Object
implements ConsumerGroupOffsetsManager

Constructor Summary

Constructors

Constructor	Description
ConsumerGroupOffsetsManagerImpl(org.apache.kafka.clients.admin.Admin adminClient)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<ListConsumerGroupOffsetsResultsData>	getConsumerGroupOffsets(String consumerGroupId)
CompletableFuture<UpdateConsumerGroupOffsetsResponse>	updateConsumerGroupOffsets(String consumerGroupId, UpdateConsumerGroupOffsetsRequest request)

Methods inherited from class java.lang.Object

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

Constructor Details

ConsumerGroupOffsetsManagerImpl

@Inject
public ConsumerGroupOffsetsManagerImpl(org.apache.kafka.clients.admin.Admin adminClient)

Method Details

getConsumerGroupOffsets

public CompletableFuture<ListConsumerGroupOffsetsResultsData> getConsumerGroupOffsets(String consumerGroupId)

Specified by:

getConsumerGroupOffsets in interface ConsumerGroupOffsetsManager

updateConsumerGroupOffsets

public CompletableFuture<UpdateConsumerGroupOffsetsResponse> updateConsumerGroupOffsets(@Nonnull
 String consumerGroupId,
 @Nonnull
 UpdateConsumerGroupOffsetsRequest request)

Specified by:

updateConsumerGroupOffsets in interface ConsumerGroupOffsetsManager