Package com.linkedin.venice.pubsub.adapter.kafka.consumer

Class ApacheKafkaConsumerConfig

java.lang.Object

com.linkedin.venice.pubsub.adapter.kafka.consumer.ApacheKafkaConsumerConfig

public class ApacheKafkaConsumerConfig
extends Object

Configuration for Apache Kafka consumer.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_RECEIVE_BUFFER_SIZE
static final String	KAFKA_CLIENT_ID_CONFIG
protected static final Set<String>	KAFKA_CONSUMER_CONFIG_PREFIXES
static final String	KAFKA_FETCH_MAX_BYTES_CONFIG
static final String	KAFKA_FETCH_MAX_WAIT_MS_CONFIG
static final String	KAFKA_FETCH_MIN_BYTES_CONFIG
static final String	KAFKA_GROUP_ID_CONFIG
static final String	KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG
static final String	KAFKA_MAX_POLL_RECORDS_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

KAFKA_FETCH_MIN_BYTES_CONFIG

public static final String KAFKA_FETCH_MIN_BYTES_CONFIG

See Also:

• Constant Field Values

KAFKA_FETCH_MAX_BYTES_CONFIG

public static final String KAFKA_FETCH_MAX_BYTES_CONFIG

See Also:

• Constant Field Values

KAFKA_MAX_POLL_RECORDS_CONFIG

public static final String KAFKA_MAX_POLL_RECORDS_CONFIG

See Also:

• Constant Field Values

KAFKA_FETCH_MAX_WAIT_MS_CONFIG

public static final String KAFKA_FETCH_MAX_WAIT_MS_CONFIG

See Also:

• Constant Field Values

KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG

public static final String KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG

See Also:

• Constant Field Values

KAFKA_CLIENT_ID_CONFIG

public static final String KAFKA_CLIENT_ID_CONFIG

See Also:

• Constant Field Values

KAFKA_GROUP_ID_CONFIG

public static final String KAFKA_GROUP_ID_CONFIG

See Also:

• Constant Field Values

DEFAULT_RECEIVE_BUFFER_SIZE

public static final int DEFAULT_RECEIVE_BUFFER_SIZE

See Also:

• Constant Field Values

KAFKA_CONSUMER_CONFIG_PREFIXES

protected static final Set<String> KAFKA_CONSUMER_CONFIG_PREFIXES

Method Details

toString

public String toString()

Overrides:

toString in class Object