Class BatchingCommitter (1.12.1)

public class BatchingCommitter extends ProxyService implements Committer

Inheritance

java.lang.Object > AbstractApiService > ProxyService > BatchingCommitter

Implements

Committer

Methods

commitOffset(Offset offset)

public synchronized ApiFuture<Void> commitOffset(Offset offset)
Parameter
NameDescription
offsetOffset
Returns
TypeDescription
ApiFuture<Void>

stop()

protected void stop()
Overrides

waitUntilEmpty()

public void waitUntilEmpty()
Exceptions
TypeDescription
CheckedApiException