Package org.apache.kafka.clients.consumer.internals

Class FetchBuffer

java.lang.Object

org.apache.kafka.clients.consumer.internals.FetchBuffer

All Implemented Interfaces:

AutoCloseable

public class FetchBuffer
extends Object
implements AutoCloseable

FetchBuffer buffers up the results from the broker responses as they are received. It is essentially a wrapper around a Queue of CompletedFetch. There is at most one CompletedFetch per partition in the queue.

Note: this class is thread-safe with the intention that the data will be "produced" by a background thread and consumed by the application thread.

Constructor Summary

Constructors

Constructor	Description
FetchBuffer(org.apache.kafka.common.utils.LogContext logContext)

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FetchBuffer

public FetchBuffer(org.apache.kafka.common.utils.LogContext logContext)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable