Interface PullSubscriber<T> (1.12.22)

public interface PullSubscriber<T> extends AutoCloseable

Implements

AutoCloseable

Type Parameter

NameDescription
T

Methods

nextOffset()

public abstract Optional<Offset> nextOffset()
Returns
TypeDescription
Optional<Offset>

pull()

public abstract List<T> pull()
Returns
TypeDescription
List<T>
Exceptions
TypeDescription
CheckedApiException