@InterfaceStability.Evolving public class ListConsumerGroupOffsetsResult extends Object
Admin.listConsumerGroupOffsets(String)
call.
The API of this class is evolving, see Admin
for details.
Modifier and Type | Method and Description |
---|---|
KafkaFuture<Map<String,Map<TopicPartition,OffsetAndMetadata>>> |
all()
Return a future which yields all Map
|
Map<String,KafkaFuture<Map<TopicPartition,OffsetAndMetadata>>> |
groupIdsToPartitionsAndOffsetAndMetadata()
Return a future which yields a map of group ids to a map of topic partitions to
OffsetAndMetadata objects.
|
KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> |
partitionsToOffsetAndMetadata()
Return a future which yields a map of topic partitions to OffsetAndMetadata objects.
|
public KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> partitionsToOffsetAndMetadata()
public Map<String,KafkaFuture<Map<TopicPartition,OffsetAndMetadata>>> groupIdsToPartitionsAndOffsetAndMetadata()
public KafkaFuture<Map<String,Map<TopicPartition,OffsetAndMetadata>>> all()