Class MultiPartitionCommitterImpl (0.3.4) 

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(long topicPartitionCount, MultiPartitionCommitter.CommitterFactory committerFactory)

public MultiPartitionCommitterImpl(long topicPartitionCount, MultiPartitionCommitter.CommitterFactory committerFactory)
Parameters
NameDescription
topicPartitionCountlong
committerFactoryMultiPartitionCommitter.CommitterFactory

Methods

close()

public synchronized void close()

commit(PslSourceOffset offset)

public synchronized void commit(PslSourceOffset offset)
Parameter
NameDescription
offsetPslSourceOffset