Class BatchingCommitter (1.13.8)

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
Name Description
offset Offset
Returns
Type Description
ApiFuture<Void>

stop()

protected void stop()
Overrides

waitUntilEmpty()

public void waitUntilEmpty()
Exceptions
Type Description
CheckedApiException