Interface MultiPartitionCommitter (0.3.4)

public interface MultiPartitionCommitter extends Closeable

Implements

Closeable

Methods

close()

public abstract void close()

commit(PslSourceOffset offset)

public abstract void commit(PslSourceOffset offset)
Parameter
NameDescription
offsetPslSourceOffset