public class OffsetSpec
extends java.lang.Object
KafkaAdminClient.listOffsets(Map, ListOffsetsOptions)
Modifier and Type | Class and Description |
---|---|
static class |
OffsetSpec.EarliestSpec |
static class |
OffsetSpec.LatestSpec |
static class |
OffsetSpec.TimestampSpec |
Constructor and Description |
---|
OffsetSpec() |
Modifier and Type | Method and Description |
---|---|
static OffsetSpec |
earliest()
Used to retrieve the earliest offset of a partition
|
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
|
static OffsetSpec |
latest()
Used to retrieve the latest offset of a partition
|
public static OffsetSpec latest()
public static OffsetSpec earliest()
public static OffsetSpec forTimestamp(long timestamp)
timestamp
- in milliseconds