Class CursorServiceGrpc.CursorServiceBlockingStub (1.14.3)

public static final class CursorServiceGrpc.CursorServiceBlockingStub extends AbstractBlockingStub<CursorServiceGrpc.CursorServiceBlockingStub>

A stub to allow clients to do synchronous rpc calls to service CursorService.

The 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.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractBlockingStub > CursorServiceGrpc.CursorServiceBlockingStub

Methods

build(Channel channel, CallOptions callOptions)

protected CursorServiceGrpc.CursorServiceBlockingStub build(Channel channel, CallOptions callOptions)
Parameters
Name Description
channel io.grpc.Channel
callOptions io.grpc.CallOptions
Returns
Type Description
CursorServiceGrpc.CursorServiceBlockingStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

commitCursor(CommitCursorRequest request)

public CommitCursorResponse commitCursor(CommitCursorRequest request)

Updates the committed cursor.

Parameter
Name Description
request CommitCursorRequest
Returns
Type Description
CommitCursorResponse

listPartitionCursors(ListPartitionCursorsRequest request)

public ListPartitionCursorsResponse listPartitionCursors(ListPartitionCursorsRequest request)

Returns all committed cursor information for a subscription.

Parameter
Name Description
request ListPartitionCursorsRequest
Returns
Type Description
ListPartitionCursorsResponse