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	Description
`static String`	`ALLOW_AUTO_CREATE_TOPICS_CONFIG`	`allow.auto.create.topics`
`static List<String>`	`ASSIGN_FROM_SUBSCRIBED_ASSIGNORS`
`static String`	`AUTO_COMMIT_INTERVAL_MS_CONFIG`	`auto.commit.interval.ms`
`static String`	`AUTO_INCLUDE_JMX_REPORTER_CONFIG`	Deprecated.
`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_DNS_LOOKUP_CONFIG`	`client.dns.lookup`
`static String`	`CLIENT_ID_CONFIG`	`client.id`
`static String`	`CLIENT_RACK_CONFIG`	`client.rack`
`static String`	`CONNECTIONS_MAX_IDLE_MS_CONFIG`	`connections.max.idle.ms`
`static boolean`	`DEFAULT_ALLOW_AUTO_CREATE_TOPICS`
`static String`	`DEFAULT_API_TIMEOUT_MS_CONFIG`	`default.api.timeout.ms`
`static String`	`DEFAULT_CLIENT_RACK`
`static boolean`	`DEFAULT_EXCLUDE_INTERNAL_TOPICS`
`static int`	`DEFAULT_FETCH_MAX_BYTES`
`static int`	`DEFAULT_FETCH_MAX_WAIT_MS`
`static int`	`DEFAULT_FETCH_MIN_BYTES`
`static String`	`DEFAULT_ISOLATION_LEVEL`
`static int`	`DEFAULT_MAX_PARTITION_FETCH_BYTES`
`static int`	`DEFAULT_MAX_POLL_RECORDS`
`static boolean`	`DEFAULT_STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT`
`static String`	`ENABLE_AUTO_COMMIT_CONFIG`	`enable.auto.commit`
`static String`	`EXCLUDE_INTERNAL_TOPICS_CONFIG`	`exclude.internal.topics`
`static String`	`FETCH_MAX_BYTES_CONFIG`	`fetch.max.bytes`
`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`	`GROUP_INSTANCE_ID_CONFIG`	`group.instance.id`
`static String`	`HEARTBEAT_INTERVAL_MS_CONFIG`	`heartbeat.interval.ms`
`static String`	`INTERCEPTOR_CLASSES_CONFIG`	`interceptor.classes`
`static String`	`INTERCEPTOR_CLASSES_DOC`
`static String`	`ISOLATION_LEVEL_CONFIG`	`isolation.level`
`static String`	`ISOLATION_LEVEL_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_INTERVAL_MS_CONFIG`	`max.poll.interval.ms`
`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_ENABLED_CONFIG`	`metrics.enabled`
`static String`	`METRICS_NUM_SAMPLES_CONFIG`	`metrics.num.samples`
`static String`	`METRICS_RECORDING_LEVEL_CONFIG`	`metrics.log.level`
`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_MAX_MS_CONFIG`	`reconnect.backoff.max.ms`
`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`	`SECURITY_PROVIDERS_CONFIG`	`security.providers`
`static String`	`SEND_BUFFER_CONFIG`	`send.buffer.bytes`
`static String`	`SESSION_TIMEOUT_MS_CONFIG`	`session.timeout.ms`
`static String`	`SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG`	`socket.connection.setup.timeout.max.ms`
`static String`	`SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG`	`socket.connection.setup.timeout.ms`
`static String`	`STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_CONFIG`	`streams.clientside.partition.assignment`
`static String`	`STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_INTERNAL_STREAM`	`streams.clientside.partition.assignment`
`static String`	`STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG`	`streams.consumer.buffer.memory`
`static String`	`STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG`	`streams.consumer.default.stream`
`static String`	`STREAMS_DEFAULT_INTERNAL_STREAM_CONFIG`	`streams.default.internal.stream`
`static String`	`STREAMS_HARDMOUNT_CONFIG`	`fs.mapr.hardmount`
`static String`	`STREAMS_NEGATIVEOFFSET_RECORD_ON_EOF_CONFIG`
`static String`	`STREAMS_RECORD_STRIP_STREAMPATH_CONFIG`	`streams.record.strip.streampath`
`static String`	`STREAMS_RPC_TIMEOUT_MS_CONFIG`	`streams.rpc.timeout.ms`
`static String`	`STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG`
`static String`	`USE_BROKERS_CONFIG`	`use.brokers`
`static String`	`VALUE_DESERIALIZER_CLASS_CONFIG`	`value.deserializer`
`static String`	`VALUE_DESERIALIZER_CLASS_DOC`

Fields inherited from class org.apache.kafka.common.config.AbstractConfig
CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors
Constructor Description

ConsumerConfig(Map<String,Object> props)

ConsumerConfig(Properties props)

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static ConfigDef`	`configDef()`
`static Set<String>`	`configNames()`
`static void`	`main(String[] args)`

Methods inherited from class org.apache.kafka.common.config.AbstractConfig
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - ASSIGN_FROM_SUBSCRIBED_ASSIGNORS
```
public static final List<String> ASSIGN_FROM_SUBSCRIBED_ASSIGNORS
```
  - GROUP_ID_CONFIG
```
public static final String GROUP_ID_CONFIG
```
    group.id
    
    See Also:
    
    Constant Field Values
  - GROUP_INSTANCE_ID_CONFIG
```
public static final String GROUP_INSTANCE_ID_CONFIG
```
    group.instance.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
  - DEFAULT_MAX_POLL_RECORDS
```
public static final int DEFAULT_MAX_POLL_RECORDS
```
    See Also:
    
    Constant Field Values
  - MAX_POLL_INTERVAL_MS_CONFIG
```
public static final String MAX_POLL_INTERVAL_MS_CONFIG
```
    max.poll.interval.ms
    
    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
  - CLIENT_DNS_LOOKUP_CONFIG
```
public static final String CLIENT_DNS_LOOKUP_CONFIG
```
    client.dns.lookup
    
    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
  - DEFAULT_FETCH_MIN_BYTES
```
public static final int DEFAULT_FETCH_MIN_BYTES
```
    See Also:
    
    Constant Field Values
  - FETCH_MAX_BYTES_CONFIG
```
public static final String FETCH_MAX_BYTES_CONFIG
```
    fetch.max.bytes
    
    See Also:
    
    Constant Field Values
  - DEFAULT_FETCH_MAX_BYTES
```
public static final int DEFAULT_FETCH_MAX_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
  - DEFAULT_FETCH_MAX_WAIT_MS
```
public static final int DEFAULT_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
  - CLIENT_RACK_CONFIG
```
public static final String CLIENT_RACK_CONFIG
```
    client.rack
    
    See Also:
    
    Constant Field Values
  - DEFAULT_CLIENT_RACK
```
public static final String DEFAULT_CLIENT_RACK
```
    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
  - RECONNECT_BACKOFF_MAX_MS_CONFIG
```
public static final String RECONNECT_BACKOFF_MAX_MS_CONFIG
```
    reconnect.backoff.max.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
  - METRICS_RECORDING_LEVEL_CONFIG
```
public static final String METRICS_RECORDING_LEVEL_CONFIG
```
    metrics.log.level
    
    See Also:
    
    Constant Field Values
  - METRIC_REPORTER_CLASSES_CONFIG
```
public static final String METRIC_REPORTER_CLASSES_CONFIG
```
    metric.reporters
    
    See Also:
    
    Constant Field Values
  - AUTO_INCLUDE_JMX_REPORTER_CONFIG
```
@Deprecated
public static final String AUTO_INCLUDE_JMX_REPORTER_CONFIG
```
    Deprecated.
    
    auto.include.jmx.reporter
    
    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
  - SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
```
public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
```
    socket.connection.setup.timeout.ms
    
    See Also:
    
    Constant Field Values
  - SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
```
public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG
```
    socket.connection.setup.timeout.max.ms
    
    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
  - DEFAULT_API_TIMEOUT_MS_CONFIG
```
public static final String DEFAULT_API_TIMEOUT_MS_CONFIG
```
    default.api.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
  - ISOLATION_LEVEL_CONFIG
```
public static final String ISOLATION_LEVEL_CONFIG
```
    isolation.level
    
    See Also:
    
    Constant Field Values
  - ISOLATION_LEVEL_DOC
```
public static final String ISOLATION_LEVEL_DOC
```
    See Also:
    
    Constant Field Values
  - DEFAULT_ISOLATION_LEVEL
```
public static final String DEFAULT_ISOLATION_LEVEL
```
  - ALLOW_AUTO_CREATE_TOPICS_CONFIG
```
public static final String ALLOW_AUTO_CREATE_TOPICS_CONFIG
```
    allow.auto.create.topics
    
    See Also:
    
    Constant Field Values
  - DEFAULT_ALLOW_AUTO_CREATE_TOPICS
```
public static final boolean DEFAULT_ALLOW_AUTO_CREATE_TOPICS
```
    See Also:
    
    Constant Field Values
  - SECURITY_PROVIDERS_CONFIG
```
public static final String SECURITY_PROVIDERS_CONFIG
```
    security.providers
    
    See Also:
    
    Constant Field Values
  - USE_BROKERS_CONFIG
```
public static final String USE_BROKERS_CONFIG
```
    use.brokers
    
    See Also:
    
    Constant Field Values
  - STREAMS_RPC_TIMEOUT_MS_CONFIG
```
public static final String STREAMS_RPC_TIMEOUT_MS_CONFIG
```
    streams.rpc.timeout.ms
    
    See Also:
    
    Constant Field Values
  - STREAMS_HARDMOUNT_CONFIG
```
public static final String STREAMS_HARDMOUNT_CONFIG
```
    fs.mapr.hardmount
    
    See Also:
    
    Constant Field Values
  - STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG
```
public static final String STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG
```
    streams.consumer.default.stream
    
    See Also:
    
    Constant Field Values
  - STREAMS_RECORD_STRIP_STREAMPATH_CONFIG
```
public static final String STREAMS_RECORD_STRIP_STREAMPATH_CONFIG
```
    streams.record.strip.streampath
    
    See Also:
    
    Constant Field Values
  - STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG
```
public static final String STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG
```
    streams.consumer.buffer.memory
    
    See Also:
    
    Constant Field Values
  - STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG
```
public static final String STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG
```
    See Also:
    
    Constant Field Values
  - STREAMS_NEGATIVEOFFSET_RECORD_ON_EOF_CONFIG
```
public static final String STREAMS_NEGATIVEOFFSET_RECORD_ON_EOF_CONFIG
```
    See Also:
    
    Constant Field Values
  - STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_CONFIG
```
public static final String STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_CONFIG
```
    streams.clientside.partition.assignment
    
    See Also:
    
    Constant Field Values
  - DEFAULT_STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT
```
public static final boolean DEFAULT_STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT
```
    See Also:
    
    Constant Field Values
  - STREAMS_DEFAULT_INTERNAL_STREAM_CONFIG
```
public static final String STREAMS_DEFAULT_INTERNAL_STREAM_CONFIG
```
    streams.default.internal.stream
    
    See Also:
    
    Constant Field Values
  - STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_INTERNAL_STREAM
```
public static final String STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_INTERNAL_STREAM
```
    streams.clientside.partition.assignment
    
    See Also:
    
    Constant Field Values
  - METRICS_ENABLED_CONFIG
```
public static final String METRICS_ENABLED_CONFIG
```
    metrics.enabled
    
    See Also:
    
    Constant Field Values
- Constructor Detail
  - ConsumerConfig
```
public ConsumerConfig(Properties props)
```
  - ConsumerConfig
```
public ConsumerConfig(Map<String,Object> props)
```
- Method Detail
  - configNames
```
public static Set<String> configNames()
```
  - configDef
```
public static ConfigDef configDef()
```
  - main
```
public static void main(String[] args)
```

Constructor	Description
`ConsumerConfig(Map<String,Object> props)`
`ConsumerConfig(Properties props)`

Class ConsumerConfig

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

ASSIGN_FROM_SUBSCRIBED_ASSIGNORS

GROUP_ID_CONFIG

GROUP_INSTANCE_ID_CONFIG

MAX_POLL_RECORDS_CONFIG

DEFAULT_MAX_POLL_RECORDS

MAX_POLL_INTERVAL_MS_CONFIG

SESSION_TIMEOUT_MS_CONFIG

HEARTBEAT_INTERVAL_MS_CONFIG

BOOTSTRAP_SERVERS_CONFIG

CLIENT_DNS_LOOKUP_CONFIG

ENABLE_AUTO_COMMIT_CONFIG

AUTO_COMMIT_INTERVAL_MS_CONFIG

PARTITION_ASSIGNMENT_STRATEGY_CONFIG

AUTO_OFFSET_RESET_CONFIG

AUTO_OFFSET_RESET_DOC

FETCH_MIN_BYTES_CONFIG

DEFAULT_FETCH_MIN_BYTES

FETCH_MAX_BYTES_CONFIG

DEFAULT_FETCH_MAX_BYTES

FETCH_MAX_WAIT_MS_CONFIG

DEFAULT_FETCH_MAX_WAIT_MS

METADATA_MAX_AGE_CONFIG

MAX_PARTITION_FETCH_BYTES_CONFIG

DEFAULT_MAX_PARTITION_FETCH_BYTES

SEND_BUFFER_CONFIG

RECEIVE_BUFFER_CONFIG

CLIENT_ID_CONFIG

CLIENT_RACK_CONFIG

DEFAULT_CLIENT_RACK

RECONNECT_BACKOFF_MS_CONFIG

RECONNECT_BACKOFF_MAX_MS_CONFIG

RETRY_BACKOFF_MS_CONFIG

METRICS_SAMPLE_WINDOW_MS_CONFIG

METRICS_NUM_SAMPLES_CONFIG

METRICS_RECORDING_LEVEL_CONFIG

METRIC_REPORTER_CLASSES_CONFIG

AUTO_INCLUDE_JMX_REPORTER_CONFIG

CHECK_CRCS_CONFIG

KEY_DESERIALIZER_CLASS_CONFIG

KEY_DESERIALIZER_CLASS_DOC

VALUE_DESERIALIZER_CLASS_CONFIG

VALUE_DESERIALIZER_CLASS_DOC

SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG

SOCKET_CONNECTION_SETUP_TIMEOUT_MAX_MS_CONFIG

CONNECTIONS_MAX_IDLE_MS_CONFIG

REQUEST_TIMEOUT_MS_CONFIG

DEFAULT_API_TIMEOUT_MS_CONFIG

INTERCEPTOR_CLASSES_CONFIG

INTERCEPTOR_CLASSES_DOC

EXCLUDE_INTERNAL_TOPICS_CONFIG

DEFAULT_EXCLUDE_INTERNAL_TOPICS

ISOLATION_LEVEL_CONFIG

ISOLATION_LEVEL_DOC

DEFAULT_ISOLATION_LEVEL

ALLOW_AUTO_CREATE_TOPICS_CONFIG

DEFAULT_ALLOW_AUTO_CREATE_TOPICS

SECURITY_PROVIDERS_CONFIG

USE_BROKERS_CONFIG

STREAMS_RPC_TIMEOUT_MS_CONFIG

STREAMS_HARDMOUNT_CONFIG

STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG

STREAMS_RECORD_STRIP_STREAMPATH_CONFIG

STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG

STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG

STREAMS_NEGATIVEOFFSET_RECORD_ON_EOF_CONFIG

STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_CONFIG

DEFAULT_STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT

STREAMS_DEFAULT_INTERNAL_STREAM_CONFIG

STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_INTERNAL_STREAM

METRICS_ENABLED_CONFIG

Constructor Detail

ConsumerConfig