ConsumerGroupOffsetsManager (ce-kafka-rest-extensions 8.2.0-ce API)

All Known Implementing Classes:: ConsumerGroupOffsetsManagerImpl

public interface ConsumerGroupOffsetsManager

Method Summary

Modifier and Type

Method

Description

CompletableFuture<ListConsumerGroupOffsetsResultsData>

getConsumerGroupOffsets(String consumerGroupId)

CompletableFuture<UpdateConsumerGroupOffsetsResponse>

updateConsumerGroupOffsets(String consumerGroupId, UpdateConsumerGroupOffsetsRequest request)

Method Details
- getConsumerGroupOffsets
  
  CompletableFuture<ListConsumerGroupOffsetsResultsData> getConsumerGroupOffsets(@Nonnull String consumerGroupId)
- updateConsumerGroupOffsets
  
  CompletableFuture<UpdateConsumerGroupOffsetsResponse> updateConsumerGroupOffsets(@Nonnull String consumerGroupId, @Nonnull UpdateConsumerGroupOffsetsRequest request)