Package org.apache.kafka.clients.admin
Class OffsetSpec
- java.lang.Object
-
- org.apache.kafka.clients.admin.OffsetSpec
-
- Direct Known Subclasses:
OffsetSpec.EarliestSpec
,OffsetSpec.LatestSpec
,OffsetSpec.MaxTimestampSpec
,OffsetSpec.TimestampSpec
public class OffsetSpec extends Object
This class allows to specify the desired offsets when usingKafkaAdminClient.listOffsets(Map, ListOffsetsOptions)
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
OffsetSpec.EarliestSpec
static class
OffsetSpec.LatestSpec
static class
OffsetSpec.MaxTimestampSpec
static class
OffsetSpec.TimestampSpec
-
Constructor Summary
Constructors Constructor Description OffsetSpec()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static OffsetSpec
earliest()
Used to retrieve the earliest offset of a partitionstatic OffsetSpec
forTimestamp(long timestamp)
Used to retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partitionstatic OffsetSpec
latest()
Used to retrieve the latest offset of a partitionstatic OffsetSpec
maxTimestamp()
Used to retrieve the offset with the largest timestamp of a partition as message timestamps can be specified client side this may not match the log end offset returned by LatestSpec
-
-
-
Method Detail
-
latest
public static OffsetSpec latest()
Used to retrieve the latest offset of a partition
-
earliest
public static OffsetSpec earliest()
Used to retrieve the earliest offset of a partition
-
forTimestamp
public static OffsetSpec forTimestamp(long timestamp)
Used to retrieve the earliest offset whose timestamp is greater than or equal to the given timestamp in the corresponding partition- Parameters:
timestamp
- in milliseconds
-
maxTimestamp
public static OffsetSpec maxTimestamp()
Used to retrieve the offset with the largest timestamp of a partition as message timestamps can be specified client side this may not match the log end offset returned by LatestSpec
-
-