Package org.apache.kafka.clients.admin
Class ListOffsetsResult
- java.lang.Object
-
- org.apache.kafka.clients.admin.ListOffsetsResult
-
@Evolving public class ListOffsetsResult extends java.lang.Object
The result of theAdmin.listOffsets(Map)
call. The API of this class is evolving, seeAdminClient
for details.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ListOffsetsResult.ListOffsetsResultInfo
-
Constructor Summary
Constructors Constructor Description ListOffsetsResult(java.util.Map<TopicPartition,KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo>> futures)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KafkaFuture<java.util.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.
-
-
-
Constructor Detail
-
ListOffsetsResult
public ListOffsetsResult(java.util.Map<TopicPartition,KafkaFuture<ListOffsetsResult.ListOffsetsResultInfo>> futures)
-
-
Method Detail
-
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<java.util.Map<TopicPartition,ListOffsetsResult.ListOffsetsResultInfo>> all()
Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.
-
-