Interface | Description |
---|---|
StartCursor |
A interface for users to specify the start position of a pulsar subscription.
|
StopCursor |
A interface for users to specify the stop position of a pulsar subscription.
|
Class | Description |
---|---|
CursorPosition |
The class for defining the start or stop position.
|
MessageIdUtils |
The helper class for Pulsar's message id.
|
Enum | Description |
---|---|
CursorPosition.Type |
The position type for reader to choose whether timestamp or message id as the start position.
|
StopCursor.StopCondition |
The conditional for control the stop behavior of the pulsar source.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.