public static interface CursorServiceGrpc.AsyncServiceThe service that a subscriber client application uses to manage committed cursors while receiving messsages. A cursor represents a subscriber's progress within a topic partition for a given subscription.
Methods
commitCursor(CommitCursorRequest request, StreamObserver<CommitCursorResponse> responseObserver)
public default void commitCursor(CommitCursorRequest request, StreamObserver<CommitCursorResponse> responseObserver)Updates the committed cursor.
| Parameters | |
|---|---|
| Name | Description |
request | CommitCursorRequest |
responseObserver | io.grpc.stub.StreamObserver<CommitCursorResponse> |
listPartitionCursors(ListPartitionCursorsRequest request, StreamObserver<ListPartitionCursorsResponse> responseObserver)
public default void listPartitionCursors(ListPartitionCursorsRequest request, StreamObserver<ListPartitionCursorsResponse> responseObserver)Returns all committed cursor information for a subscription.
| Parameters | |
|---|---|
| Name | Description |
request | ListPartitionCursorsRequest |
responseObserver | io.grpc.stub.StreamObserver<ListPartitionCursorsResponse> |
streamingCommitCursor(StreamObserver<StreamingCommitCursorResponse> responseObserver)
public default StreamObserver<StreamingCommitCursorRequest> streamingCommitCursor(StreamObserver<StreamingCommitCursorResponse> responseObserver)Establishes a stream with the server for managing committed cursors.
| Parameter | |
|---|---|
| Name | Description |
responseObserver | io.grpc.stub.StreamObserver<StreamingCommitCursorResponse> |
| Returns | |
|---|---|
| Type | Description |
io.grpc.stub.StreamObserver<StreamingCommitCursorRequest> | |