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–2022. All rights reserved.