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_AUTO_OFFSET_RESET_CONFIG
static final String	KAFKA_CLIENT_ID_CONFIG
static final String	KAFKA_ENABLE_AUTO_COMMIT_CONFIG
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
static Properties	getValidConsumerProperties(Properties extractedProperties)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

KAFKA_AUTO_OFFSET_RESET_CONFIG

public static final String KAFKA_AUTO_OFFSET_RESET_CONFIG

See Also:

• Constant Field Values

KAFKA_ENABLE_AUTO_COMMIT_CONFIG

public static final String KAFKA_ENABLE_AUTO_COMMIT_CONFIG

See Also:

• Constant Field Values

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

Method Details

toString

public String toString()

Overrides:

toString in class Object

getValidConsumerProperties

public static Properties getValidConsumerProperties(Properties extractedProperties)