org.apache.kafka.clients.admin.ListOffsetsResult

public class ListOffsetsResultextends Object

The result of the Admin.listOffsets(Map) call.

Nested Class Summary
Nested Classes
Modifier and Type
Class
Description
static class
ListOffsetsResult.ListOffsetsResultInfo
Constructor Summary
Constructors
Constructor
Description
ListOffsetsResult(Map<TopicPartition, KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo>> futures)
Method Summary
Modifier and Type
Method
Description
KafkaFuture<Map<TopicPartition, ListOffsetsResult.ListOffsetsResultInfo>>
all()
Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.
KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo>
partitionResult(TopicPartition partition)
Return a future which can be used to check the result for a given partition.
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- ListOffsetsResult
  public ListOffsetsResult(Map<TopicPartition, KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo>> futures)
Method Details
- partitionResult
  public KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo> partitionResult(TopicPartition partition)
  Return a future which can be used to check the result for a given partition.
- all
  public KafkaFuture<Map<TopicPartition, ListOffsetsResult.ListOffsetsResultInfo>> all()
  Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.

Class ListOffsetsResult

Nested Class Summary