Class CursorClientImpl (1.10.0)

public class CursorClientImpl extends ApiResourceAggregation implements CursorClient

Inheritance

java.lang.Object > ApiResourceAggregation > CursorClientImpl

Implements

CursorClient

Constructors

CursorClientImpl(CloudRegion region, CursorServiceClient serviceClient)

public CursorClientImpl(CloudRegion region, CursorServiceClient serviceClient)
Parameters
NameDescription
regionCloudRegion
serviceClientCursorServiceClient

Methods

commitCursor(SubscriptionPath path, Partition partition, Offset offset)

public ApiFuture<Void> commitCursor(SubscriptionPath path, Partition partition, Offset offset)

Commit a single cursor.

Parameters
NameDescription
pathSubscriptionPath
partitionPartition
offsetOffset
Returns
TypeDescription
ApiFuture<Void>

listPartitionCursors(SubscriptionPath path)

public ApiFuture<Map<Partition,Offset>> listPartitionCursors(SubscriptionPath path)

List the cursors for a given subscription.

Parameter
NameDescription
pathSubscriptionPath
Returns
TypeDescription
ApiFuture<Map<Partition,Offset>>

region()

public CloudRegion region()

The Google Cloud region this client operates on.

Returns
TypeDescription
CloudRegion