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 java.lang.Object

Configuration for Apache Kafka consumer.

Field Summary

Fields

Modifier and Type	Field	Description
static int	DEFAULT_RECEIVE_BUFFER_SIZE
static java.lang.String	KAFKA_AUTO_OFFSET_RESET_CONFIG
static java.lang.String	KAFKA_CLIENT_ID_CONFIG
static java.lang.String	KAFKA_ENABLE_AUTO_COMMIT_CONFIG
static java.lang.String	KAFKA_FETCH_MAX_BYTES_CONFIG
static java.lang.String	KAFKA_FETCH_MAX_WAIT_MS_CONFIG
static java.lang.String	KAFKA_FETCH_MIN_BYTES_CONFIG
static java.lang.String	KAFKA_GROUP_ID_CONFIG
static java.lang.String	KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG
static java.lang.String	KAFKA_MAX_POLL_RECORDS_CONFIG

Method Summary

Modifier and Type	Method	Description
static java.util.Properties	getValidConsumerProperties(java.util.Properties extractedProperties)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

KAFKA_AUTO_OFFSET_RESET_CONFIG

public static final java.lang.String KAFKA_AUTO_OFFSET_RESET_CONFIG

See Also:

Constant Field Values

KAFKA_ENABLE_AUTO_COMMIT_CONFIG

public static final java.lang.String KAFKA_ENABLE_AUTO_COMMIT_CONFIG

See Also:

Constant Field Values

KAFKA_FETCH_MIN_BYTES_CONFIG

public static final java.lang.String KAFKA_FETCH_MIN_BYTES_CONFIG

See Also:

Constant Field Values

KAFKA_FETCH_MAX_BYTES_CONFIG

public static final java.lang.String KAFKA_FETCH_MAX_BYTES_CONFIG

See Also:

Constant Field Values

KAFKA_MAX_POLL_RECORDS_CONFIG

public static final java.lang.String KAFKA_MAX_POLL_RECORDS_CONFIG

See Also:

Constant Field Values

KAFKA_FETCH_MAX_WAIT_MS_CONFIG

public static final java.lang.String KAFKA_FETCH_MAX_WAIT_MS_CONFIG

See Also:

Constant Field Values

KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG

public static final java.lang.String KAFKA_MAX_PARTITION_FETCH_BYTES_CONFIG

See Also:

Constant Field Values

KAFKA_CLIENT_ID_CONFIG

public static final java.lang.String KAFKA_CLIENT_ID_CONFIG

See Also:

Constant Field Values

KAFKA_GROUP_ID_CONFIG

public static final java.lang.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 Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getValidConsumerProperties

public static java.util.Properties getValidConsumerProperties(java.util.Properties extractedProperties)