Class MultiPartitionCommitterImpl (1.0.0) 

public class MultiPartitionCommitterImpl implements MultiPartitionCommitter

A MultiPartitionCommitter that lazily adjusts for partition changes when MultiPartitionCommitter#commit(PslSourceOffset) is called.

Inheritance

java.lang.Object > MultiPartitionCommitterImpl

Constructors

MultiPartitionCommitterImpl(SubscriptionPath subscription, CursorClient client)

public MultiPartitionCommitterImpl(SubscriptionPath subscription, CursorClient client)
Parameters
Name Description
subscription com.google.cloud.pubsublite.SubscriptionPath
client com.google.cloud.pubsublite.internal.CursorClient

Methods

close()

public void close()

commit(PslSourceOffset offset)

public void commit(PslSourceOffset offset)
Parameter
Name Description
offset PslSourceOffset