@InterfaceStability.Evolving public class ListConsumerGroupOffsetsResult extends Object
Admin.listConsumerGroupOffsets(Map) and 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 |
KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> | partitionsToOffsetAndMetadata()Return a future which yields a map of topic partitions to OffsetAndMetadata objects. |
KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> | partitionsToOffsetAndMetadata(String groupId)Return a future which yields a map of topic partitions to OffsetAndMetadata objects for the specified group. |
public KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> partitionsToOffsetAndMetadata()
public KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> partitionsToOffsetAndMetadata(String groupId)
public KafkaFuture<Map<String,Map<TopicPartition,OffsetAndMetadata>>> all()