Class MultiPartitionCommitterImpl (0.3.4)

Version 0.3.4

• 1.0.0 (latest)
• 0.4.5
• 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

Implements

MultiPartitionCommitter

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

MultiPartitionCommitterImpl(long topicPartitionCount, MultiPartitionCommitter.CommitterFactory committerFactory)

public MultiPartitionCommitterImpl(long topicPartitionCount, MultiPartitionCommitter.CommitterFactory committerFactory)

Parameters

Name	Description
topicPartitionCount	long
committerFactory	MultiPartitionCommitter.CommitterFactory

Methods

close()

public synchronized void close()

commit(PslSourceOffset offset)

public synchronized void commit(PslSourceOffset offset)

Parameter

Name	Description
offset	PslSourceOffset