Interface Committer (1.12.5)

public interface Committer extends ApiService

Implements

ApiService

Methods

commitOffset(Offset offset)

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

waitUntilEmpty()

public abstract void waitUntilEmpty()
Exceptions
TypeDescription
CheckedApiException