Package org.apache.kafka.clients.admin

Class ListConsumerGroupOffsetsResult

java.lang.Object

org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult

public class ListConsumerGroupOffsetsResult
extends Object

The result of the Admin.listConsumerGroupOffsets(Map) and Admin.listConsumerGroupOffsets(String) call.

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

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

Method Details

partitionsToOffsetAndMetadata

public KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> partitionsToOffsetAndMetadata()

Return a future which yields a map of topic partitions to OffsetAndMetadata objects. If the group does not have a committed offset for this partition, the corresponding value in the returned map will be null.

partitionsToOffsetAndMetadata

public KafkaFuture<Map<TopicPartition,OffsetAndMetadata>> partitionsToOffsetAndMetadata(String groupId)

Return a future which yields a map of topic partitions to OffsetAndMetadata objects for the specified group. If the group doesn't have a committed offset for a specific partition, the corresponding value in the returned map will be null.

all

public 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.