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
NameDescription
subscriptioncom.google.cloud.pubsublite.SubscriptionPath
clientcom.google.cloud.pubsublite.internal.CursorClient

Methods

close()

public void close()

commit(PslSourceOffset offset)

public void commit(PslSourceOffset offset)
Parameter
NameDescription
offsetPslSourceOffset