public static class CreateCursorDetails.Builder extends Object
Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
CreateCursorDetails |
build() |
CreateCursorDetails.Builder |
copy(CreateCursorDetails model) |
CreateCursorDetails.Builder |
offset(Long offset)
The offset to consume from if the cursor type is
AT_OFFSET or AFTER_OFFSET . |
CreateCursorDetails.Builder |
partition(String partition)
The partition to get messages from.
|
CreateCursorDetails.Builder |
time(Date time)
The time to consume from if the cursor type is
AT_TIME , expressed in RFC
3339 timestamp format. |
CreateCursorDetails.Builder |
type(CreateCursorDetails.Type type)
The type of cursor, which determines the starting point from which the stream will be
consumed:
|
public CreateCursorDetails.Builder partition(String partition)
The partition to get messages from.
partition
- the value to setpublic CreateCursorDetails.Builder type(CreateCursorDetails.Type type)
The type of cursor, which determines the starting point from which the stream will be consumed:
- AFTER_OFFSET:
The partition position immediately following the offset you
specify. (Offsets are assigned when you successfully append a message to a partition in a
stream.) - AT_OFFSET:
The exact partition position indicated by the offset you
specify. - AT_TIME:
A specific point in time. - LATEST:
The most recent
message in the partition that was added after the cursor was created. - TRIM_HORIZON:
The oldest message in the partition that is within the retention period
window.
type
- the value to setpublic CreateCursorDetails.Builder offset(Long offset)
The offset to consume from if the cursor type is AT_OFFSET
or AFTER_OFFSET
.
offset
- the value to setpublic CreateCursorDetails.Builder time(Date time)
The time to consume from if the cursor type is AT_TIME
, expressed in RFC
3339 timestamp format.
time
- the value to setpublic CreateCursorDetails build()
public CreateCursorDetails.Builder copy(CreateCursorDetails model)
Copyright © 2016–2024. All rights reserved.