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

Class FetchConfig

java.lang.Object

org.apache.kafka.clients.consumer.internals.FetchConfig

public class FetchConfig
extends Object

FetchConfig represents the static configuration for fetching records from Kafka. It is simply a way to bundle the immutable settings that were presented at the time the Consumer was created for later use by classes like Fetcher, CompletedFetch, etc.

Field Summary

Fields

Modifier and Type	Field	Description
final boolean	checkCrcs
final String	clientRackId
final int	fetchSize
final org.apache.kafka.common.IsolationLevel	isolationLevel
final int	maxBytes
final int	maxPollRecords
final int	maxWaitMs
final int	minBytes

Constructor Summary

Constructors

Constructor	Description
FetchConfig(int minBytes, int maxBytes, int maxWaitMs, int fetchSize, int maxPollRecords, boolean checkCrcs, String clientRackId, org.apache.kafka.common.IsolationLevel isolationLevel)	Constructs a new FetchConfig using explicitly provided values.
FetchConfig(ConsumerConfig config)	Constructs a new FetchConfig using values from the given consumer configuration settings: minBytes: ConsumerConfig.FETCH_MIN_BYTES_CONFIG maxBytes: ConsumerConfig.FETCH_MAX_BYTES_CONFIG maxWaitMs: ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG fetchSize: ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG maxPollRecords: ConsumerConfig.MAX_POLL_RECORDS_CONFIG checkCrcs: ConsumerConfig.CHECK_CRCS_CONFIG clientRackId: ConsumerConfig.CLIENT_RACK_CONFIG isolationLevel: ConsumerConfig.ISOLATION_LEVEL_CONFIG

Method Summary

Modifier and Type	Method	Description
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

minBytes

public final int minBytes

maxBytes

public final int maxBytes

maxWaitMs

public final int maxWaitMs

fetchSize

public final int fetchSize

maxPollRecords

public final int maxPollRecords

checkCrcs

public final boolean checkCrcs

clientRackId

public final String clientRackId

isolationLevel

public final org.apache.kafka.common.IsolationLevel isolationLevel

Constructor Details

FetchConfig

public FetchConfig(int minBytes,
 int maxBytes,
 int maxWaitMs,
 int fetchSize,
 int maxPollRecords,
 boolean checkCrcs,
 String clientRackId,
 org.apache.kafka.common.IsolationLevel isolationLevel)

Constructs a new FetchConfig using explicitly provided values. This is provided here for tests that want to exercise different scenarios can construct specific configuration values rather than going through the hassle of constructing a ConsumerConfig.

FetchConfig

public FetchConfig(ConsumerConfig config)

Constructs a new FetchConfig using values from the given consumer configuration settings:

• minBytes: ConsumerConfig.FETCH_MIN_BYTES_CONFIG
• maxBytes: ConsumerConfig.FETCH_MAX_BYTES_CONFIG
• maxWaitMs: ConsumerConfig.FETCH_MAX_WAIT_MS_CONFIG
• fetchSize: ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG
• maxPollRecords: ConsumerConfig.MAX_POLL_RECORDS_CONFIG
• checkCrcs: ConsumerConfig.CHECK_CRCS_CONFIG
• clientRackId: ConsumerConfig.CLIENT_RACK_CONFIG
• isolationLevel: ConsumerConfig.ISOLATION_LEVEL_CONFIG

Parameters:

config - Consumer configuration

Method Details

toString

public String toString()

Overrides:

toString in class Object