Class ResolveOffsetRangeResult

java.lang.Object

org.apache.kafka.clients.admin.ResolveOffsetRangeResult

@Evolving
public class ResolveOffsetRangeResult
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ResolveOffsetRangeResult.EncryptionMetadata
static class	ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo
static class	ResolveOffsetRangeResult.TieredFile
static class	ResolveOffsetRangeResult.TieredRange

Constructor Summary

Constructors

Constructor	Description
ResolveOffsetRangeResult(Map<TopicIdAndPartition, KafkaFuture<ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo>> futures)

Method Summary

Modifier and Type	Method	Description
KafkaFuture<Map<TopicIdAndPartition, ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo>>	all()	Return a future which succeeds only if offsets for all specified partitions have been successfully retrieved.
KafkaFuture<ResolveOffsetRangeResult.ResolveOffsetRangeResultInfo>	partitionResult(TopicIdAndPartition 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

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.