org.apache.kafka.clients.consumer

Class ConsumerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

org.apache.kafka.clients.consumer.ConsumerConfig

public class ConsumerConfig
extends AbstractConfig

The consumer configuration keys

Field Summary

Fields

Modifier and Type	Field and Description
static String	AUTO_COMMIT_INTERVAL_MS_CONFIG auto.commit.interval.ms
static String	AUTO_OFFSET_RESET_CONFIG auto.offset.reset
static String	AUTO_OFFSET_RESET_DOC
static String	BOOTSTRAP_SERVERS_CONFIG bootstrap.servers
static String	CHECK_CRCS_CONFIG check.crcs
static String	CLIENT_ID_CONFIG client.id
static String	CONNECTIONS_MAX_IDLE_MS_CONFIG connections.max.idle.ms
static boolean	DEFAULT_EXCLUDE_INTERNAL_TOPICS
static int	DEFAULT_MAX_PARTITION_FETCH_BYTES
static String	ENABLE_AUTO_COMMIT_CONFIG enable.auto.commit
static String	EXCLUDE_INTERNAL_TOPICS_CONFIG exclude.internal.topics
static String	FETCH_MAX_WAIT_MS_CONFIG fetch.max.wait.ms
static String	FETCH_MIN_BYTES_CONFIG fetch.min.bytes
static String	GROUP_ID_CONFIG group.id
static String	HEARTBEAT_INTERVAL_MS_CONFIG heartbeat.interval.ms
static String	INTERCEPTOR_CLASSES_CONFIG interceptor.classes
static String	INTERCEPTOR_CLASSES_DOC
static String	KEY_DESERIALIZER_CLASS_CONFIG key.deserializer
static String	KEY_DESERIALIZER_CLASS_DOC
static String	MAX_PARTITION_FETCH_BYTES_CONFIG max.partition.fetch.bytes
static String	MAX_POLL_RECORDS_CONFIG max.poll.records
static String	METADATA_MAX_AGE_CONFIG metadata.max.age.ms
static String	METRIC_REPORTER_CLASSES_CONFIG metric.reporters
static String	METRICS_NUM_SAMPLES_CONFIG metrics.num.samples
static String	METRICS_SAMPLE_WINDOW_MS_CONFIG metrics.sample.window.ms
static String	PARTITION_ASSIGNMENT_STRATEGY_CONFIG partition.assignment.strategy
static String	RECEIVE_BUFFER_CONFIG receive.buffer.bytes
static String	RECONNECT_BACKOFF_MS_CONFIG reconnect.backoff.ms
static String	REQUEST_TIMEOUT_MS_CONFIG request.timeout.ms
static String	RETRY_BACKOFF_MS_CONFIG retry.backoff.ms
static String	SEND_BUFFER_CONFIG send.buffer.bytes
static String	SESSION_TIMEOUT_MS_CONFIG session.timeout.ms
static String	VALUE_DESERIALIZER_CLASS_CONFIG value.deserializer
static String	VALUE_DESERIALIZER_CLASS_DOC

Method Summary

Methods

Modifier and Type	Method and Description
static Map<String,Object>	addDeserializerToConfig(Map<String,Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer)
static Properties	addDeserializerToConfig(Properties properties, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer)
static void	main(String[] args)

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, unused, values

Methods inherited from class java.lang.Object

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

Field Detail

GROUP_ID_CONFIG

public static final String GROUP_ID_CONFIG

group.id

See Also:

Constant Field Values

MAX_POLL_RECORDS_CONFIG

public static final String MAX_POLL_RECORDS_CONFIG

max.poll.records

See Also:

Constant Field Values

SESSION_TIMEOUT_MS_CONFIG

public static final String SESSION_TIMEOUT_MS_CONFIG

session.timeout.ms

See Also:

Constant Field Values

HEARTBEAT_INTERVAL_MS_CONFIG

public static final String HEARTBEAT_INTERVAL_MS_CONFIG

heartbeat.interval.ms

See Also:

Constant Field Values

BOOTSTRAP_SERVERS_CONFIG

public static final String BOOTSTRAP_SERVERS_CONFIG

bootstrap.servers

See Also:

Constant Field Values

ENABLE_AUTO_COMMIT_CONFIG

public static final String ENABLE_AUTO_COMMIT_CONFIG

enable.auto.commit

See Also:

Constant Field Values

AUTO_COMMIT_INTERVAL_MS_CONFIG

public static final String AUTO_COMMIT_INTERVAL_MS_CONFIG

auto.commit.interval.ms

See Also:

Constant Field Values

PARTITION_ASSIGNMENT_STRATEGY_CONFIG

public static final String PARTITION_ASSIGNMENT_STRATEGY_CONFIG

partition.assignment.strategy

See Also:

Constant Field Values

AUTO_OFFSET_RESET_CONFIG

public static final String AUTO_OFFSET_RESET_CONFIG

auto.offset.reset

See Also:

Constant Field Values

AUTO_OFFSET_RESET_DOC

public static final String AUTO_OFFSET_RESET_DOC

See Also:

Constant Field Values

FETCH_MIN_BYTES_CONFIG

public static final String FETCH_MIN_BYTES_CONFIG

fetch.min.bytes

See Also:

Constant Field Values

FETCH_MAX_WAIT_MS_CONFIG

public static final String FETCH_MAX_WAIT_MS_CONFIG

fetch.max.wait.ms

See Also:

Constant Field Values

METADATA_MAX_AGE_CONFIG

public static final String METADATA_MAX_AGE_CONFIG

metadata.max.age.ms

See Also:

Constant Field Values

MAX_PARTITION_FETCH_BYTES_CONFIG

public static final String MAX_PARTITION_FETCH_BYTES_CONFIG

max.partition.fetch.bytes

See Also:

Constant Field Values

DEFAULT_MAX_PARTITION_FETCH_BYTES

public static final int DEFAULT_MAX_PARTITION_FETCH_BYTES

See Also:

Constant Field Values

SEND_BUFFER_CONFIG

public static final String SEND_BUFFER_CONFIG

send.buffer.bytes

See Also:

Constant Field Values

RECEIVE_BUFFER_CONFIG

public static final String RECEIVE_BUFFER_CONFIG

receive.buffer.bytes

See Also:

Constant Field Values

CLIENT_ID_CONFIG

public static final String CLIENT_ID_CONFIG

client.id

See Also:

Constant Field Values

RECONNECT_BACKOFF_MS_CONFIG

public static final String RECONNECT_BACKOFF_MS_CONFIG

reconnect.backoff.ms

See Also:

Constant Field Values

RETRY_BACKOFF_MS_CONFIG

public static final String RETRY_BACKOFF_MS_CONFIG

retry.backoff.ms

See Also:

Constant Field Values

METRICS_SAMPLE_WINDOW_MS_CONFIG

public static final String METRICS_SAMPLE_WINDOW_MS_CONFIG

metrics.sample.window.ms

See Also:

Constant Field Values

METRICS_NUM_SAMPLES_CONFIG

public static final String METRICS_NUM_SAMPLES_CONFIG

metrics.num.samples

See Also:

Constant Field Values

METRIC_REPORTER_CLASSES_CONFIG

public static final String METRIC_REPORTER_CLASSES_CONFIG

metric.reporters

See Also:

Constant Field Values

CHECK_CRCS_CONFIG

public static final String CHECK_CRCS_CONFIG

check.crcs

See Also:

Constant Field Values

KEY_DESERIALIZER_CLASS_CONFIG

public static final String KEY_DESERIALIZER_CLASS_CONFIG

key.deserializer

See Also:

Constant Field Values

KEY_DESERIALIZER_CLASS_DOC

public static final String KEY_DESERIALIZER_CLASS_DOC

See Also:

Constant Field Values

VALUE_DESERIALIZER_CLASS_CONFIG

public static final String VALUE_DESERIALIZER_CLASS_CONFIG

value.deserializer

See Also:

Constant Field Values

VALUE_DESERIALIZER_CLASS_DOC

public static final String VALUE_DESERIALIZER_CLASS_DOC

See Also:

Constant Field Values

CONNECTIONS_MAX_IDLE_MS_CONFIG

public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG

connections.max.idle.ms

See Also:

Constant Field Values

REQUEST_TIMEOUT_MS_CONFIG

public static final String REQUEST_TIMEOUT_MS_CONFIG

request.timeout.ms

See Also:

Constant Field Values

INTERCEPTOR_CLASSES_CONFIG

public static final String INTERCEPTOR_CLASSES_CONFIG

interceptor.classes

See Also:

Constant Field Values

INTERCEPTOR_CLASSES_DOC

public static final String INTERCEPTOR_CLASSES_DOC

See Also:

Constant Field Values

EXCLUDE_INTERNAL_TOPICS_CONFIG

public static final String EXCLUDE_INTERNAL_TOPICS_CONFIG

exclude.internal.topics

See Also:

Constant Field Values

DEFAULT_EXCLUDE_INTERNAL_TOPICS

public static final boolean DEFAULT_EXCLUDE_INTERNAL_TOPICS

See Also:

Constant Field Values

Method Detail

addDeserializerToConfig

public static Map<String,Object> addDeserializerToConfig(Map<String,Object> configs,
                                         Deserializer<?> keyDeserializer,
                                         Deserializer<?> valueDeserializer)

addDeserializerToConfig

public static Properties addDeserializerToConfig(Properties properties,
                                 Deserializer<?> keyDeserializer,
                                 Deserializer<?> valueDeserializer)

main

public static void main(String[] args)