Class CursorClientImpl (1.14.1) 

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
Name Description
region CloudRegion
serviceClient CursorServiceClient

Methods

commitCursor(SubscriptionPath path, Partition partition, Offset offset)

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

Commit a single cursor.

Parameters
Name Description
path SubscriptionPath
partition Partition
offset Offset
Returns
Type Description
ApiFuture<Void>

listPartitionCursors(SubscriptionPath path)

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

List the cursors for a given subscription.

Parameter
Name Description
path SubscriptionPath
Returns
Type Description
ApiFuture<Map<Partition,Offset>>

region()

public CloudRegion region()

The Google Cloud region this client operates on.

Returns
Type Description
CloudRegion