Interface Committer (1.15.0)

public interface Committer extends ApiService

Implements

ApiService

Methods

commitOffset(Offset offset)

public abstract ApiFuture<Void> commitOffset(Offset offset)
Parameter
Name Description
offset Offset
Returns
Type Description
ApiFuture<Void>

waitUntilEmpty()

public abstract void waitUntilEmpty()
Exceptions
Type Description
CheckedApiException