Class CursorServiceGrpc.CursorServiceBlockingV2Stub (1.16.2)

1.16.2 (latest) 1.16.1 1.15.21 1.14.8 1.13.8 1.12.22 1.11.2 1.10.0 1.9.4 1.8.0 1.7.1 1.6.3 1.5.5 1.4.12

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

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

Inherited Members

io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

io.grpc.stub.AbstractStub.getCallOptions()

io.grpc.stub.AbstractStub.getChannel()

io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)

io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)

io.grpc.stub.AbstractStub.withCompression(java.lang.String)

io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)

io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)

io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)

io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)

io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)

io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)

io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)

io.grpc.stub.AbstractStub.withOnReadyThreshold(int)

io.grpc.stub.AbstractStub.withWaitForReady()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

build(Channel channel, CallOptions callOptions)

protected CursorServiceGrpc.CursorServiceBlockingV2Stub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
channel	io.grpc.Channel
callOptions	io.grpc.CallOptions

Returns
Type	Description
CursorServiceGrpc.CursorServiceBlockingV2Stub

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

Exceptions
Type	Description
io.grpc.StatusException

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

Exceptions
Type	Description
io.grpc.StatusException

streamingCommitCursor()

public BlockingClientCall<StreamingCommitCursorRequest,StreamingCommitCursorResponse> streamingCommitCursor()

Establishes a stream with the server for managing committed cursors.

Returns
Type	Description
io.grpc.stub.BlockingClientCall<StreamingCommitCursorRequest,StreamingCommitCursorResponse>