public interface CursorClient extends ApiBackgroundResource
Implements
ApiBackgroundResourceStatic Methods
create(CursorClientSettings settings)
public static CursorClient create(CursorClientSettings settings)
Name | Description |
settings | CursorClientSettings |
Type | Description |
CursorClient |
Type | Description |
ApiException |
Methods
commitCursor(SubscriptionPath path, Partition partition, Offset offset)
public abstract ApiFuture<Void> commitCursor(SubscriptionPath path, Partition partition, Offset offset)
Commit a single cursor.
Name | Description |
path | SubscriptionPath The subscription to commit a cursor for. |
partition | Partition The partition to commit a cursor for. |
offset | Offset The offset to commit. |
Type | Description |
ApiFuture<Void> | A future for the operation's completion. |
listPartitionCursors(SubscriptionPath path)
public abstract ApiFuture<Map<Partition,Offset>> listPartitionCursors(SubscriptionPath path)
List the cursors for a given subscription.
Name | Description |
path | SubscriptionPath The subscription to list cursors for. |
Type | Description |
ApiFuture<Map<Partition,Offset>> | A future holding the map of Partition to Offset of the cursors. |
region()
public abstract CloudRegion region()
The Google Cloud region this client operates on.
Type | Description |
CloudRegion |