Package org.apache.kafka.clients.admin
Class ListConsumerGroupOffsetsResult
- java.lang.Object
-
- org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult
-
@Evolving public class ListConsumerGroupOffsetsResult extends Object
The result of theAdmin.listConsumerGroupOffsets(Map)
andAdmin.listConsumerGroupOffsets(String)
call.The API of this class is evolving, see
Admin
for details.
-
-
Constructor Summary
Constructors Constructor Description ListConsumerGroupOffsetsResult(Map<org.apache.kafka.clients.admin.internals.CoordinatorKey,KafkaFuture<Map<TopicPartition,OffsetAndMetadata>>> futures)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KafkaFuture<Map<String,Map<TopicPartition,OffsetAndMetadata>>>
all()
Return a future which yields allMap<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.
-
-
-
Constructor Detail
-
ListConsumerGroupOffsetsResult
public ListConsumerGroupOffsetsResult(Map<org.apache.kafka.clients.admin.internals.CoordinatorKey,KafkaFuture<Map<TopicPartition,OffsetAndMetadata>>> futures)
-
-
Method Detail
-
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 allMap<String, Map<TopicPartition, OffsetAndMetadata>
objects, if requests for all the groups succeed.
-
-