Class ListShareGroupOffsetsResult

java.lang.Object

org.apache.kafka.clients.admin.ListShareGroupOffsetsResult

public class ListShareGroupOffsetsResult
extends Object

The result of the Admin.listShareGroupOffsets(Map, ListShareGroupOffsetsOptions) call.

Method Summary

Modifier and Type	Method	Description
KafkaFuture<Map<String, Map<TopicPartition, SharePartitionOffsetInfo>>>	all()	Return the future when the requests for all groups succeed.
KafkaFuture<Map<TopicPartition, SharePartitionOffsetInfo>>	partitionsToOffsetInfo(String groupId)	Return a future which yields a map of topic partitions to offsets for the specified group.

Methods inherited from class Object

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

Method Details

all

public KafkaFuture<Map<String, Map<TopicPartition, SharePartitionOffsetInfo>>> all()

Return the future when the requests for all groups succeed.

Returns:

Future which yields all Map<String, Map<TopicPartition, SharePartitionOffsetInfo>> objects, if requests for all the groups succeed.

partitionsToOffsetInfo

public KafkaFuture<Map<TopicPartition, SharePartitionOffsetInfo>> partitionsToOffsetInfo(String groupId)

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