@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<String, Map<TopicPartition, OffsetAndMetadata> objects,
if requests for all the groups succeed. |
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()
Map<String, Map<TopicPartition, OffsetAndMetadata>
objects,
if requests for all the groups succeed.