Interface PullSubscriber<T> (1.13.7)

public interface PullSubscriber<T> extends AutoCloseable

Implements

AutoCloseable

Type Parameter

Name Description
T

Methods

nextOffset()

public abstract Optional<Offset> nextOffset()
Returns
Type Description
Optional<Offset>

pull()

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