Interface PullSubscriber<T> (1.12.22)

Version 1.12.22

• 1.15.0 (latest)
• 1.14.8
• 1.13.8
• 1.12.22
• 1.11.2
• 1.10.0
• 1.9.4
• 1.8.0
• 1.7.1
• 1.6.3
• 1.5.5
• 1.4.12

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