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

Class CompletedFetch

java.lang.Object

org.apache.kafka.clients.consumer.internals.CompletedFetch

public class CompletedFetch
extends Object

CompletedFetch represents a batch of records that was returned from the broker via a FetchRequest. It contains logic to maintain state between calls to fetchRecords(FetchConfig, Deserializers, int).

Method Summary

Modifier and Type	Method	Description
boolean	isConsumed()

Methods inherited from class java.lang.Object

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

Method Details

isConsumed

public boolean isConsumed()