Class ResolveOffsetRangeResult
java.lang.Object
org.apache.kafka.clients.admin.ResolveOffsetRangeResult
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic classConstructor Summary
ConstructorsConstructorDescriptionResolveOffsetRangeResult(Map<TopicIdAndPartition, KafkaFuture<ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo>> futures) Method Summary
Modifier and TypeMethodDescriptionall()Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.partitionResult(TopicIdAndPartition partition) Return a future which can be used to check the result for a given partition.
Constructor Details
ResolveOffsetRangeResult
public ResolveOffsetRangeResult(Map<TopicIdAndPartition, KafkaFuture<ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo>> futures)
Method Details
partitionResult
public KafkaFuture<ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo> partitionResult(TopicIdAndPartition partition) Return a future which can be used to check the result for a given partition.all
public KafkaFuture<Map<TopicIdAndPartition, ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo>> all()Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.