Package 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 Details

    • 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:

    • GROUP_INSTANCE_ID_CONFIG

      public static final String GROUP_INSTANCE_ID_CONFIG
      group.instance.id
      See Also:

    • MAX_POLL_RECORDS_CONFIG

      public static final String MAX_POLL_RECORDS_CONFIG
      max.poll.records
      See Also:

    • DEFAULT_MAX_POLL_RECORDS

      public static final int DEFAULT_MAX_POLL_RECORDS
      See Also:

    • MAX_POLL_INTERVAL_MS_CONFIG

      public static final String MAX_POLL_INTERVAL_MS_CONFIG
      max.poll.interval.ms
      See Also:

    • SESSION_TIMEOUT_MS_CONFIG

      public static final String SESSION_TIMEOUT_MS_CONFIG
      session.timeout.ms
      See Also:

    • HEARTBEAT_INTERVAL_MS_CONFIG

      public static final String HEARTBEAT_INTERVAL_MS_CONFIG
      heartbeat.interval.ms
      See Also:

    • BOOTSTRAP_SERVERS_CONFIG

      public static final String BOOTSTRAP_SERVERS_CONFIG
      bootstrap.servers
      See Also:

    • CLIENT_DNS_LOOKUP_CONFIG

      public static final String CLIENT_DNS_LOOKUP_CONFIG
      client.dns.lookup
      See Also:

    • ENABLE_AUTO_COMMIT_CONFIG

      public static final String ENABLE_AUTO_COMMIT_CONFIG
      enable.auto.commit
      See Also:

    • AUTO_COMMIT_INTERVAL_MS_CONFIG

      public static final String AUTO_COMMIT_INTERVAL_MS_CONFIG
      auto.commit.interval.ms
      See Also:

    • PARTITION_ASSIGNMENT_STRATEGY_CONFIG

      public static final String PARTITION_ASSIGNMENT_STRATEGY_CONFIG
      partition.assignment.strategy
      See Also:

    • AUTO_OFFSET_RESET_CONFIG

      public static final String AUTO_OFFSET_RESET_CONFIG
      auto.offset.reset
      See Also:

    • AUTO_OFFSET_RESET_DOC

      public static final String AUTO_OFFSET_RESET_DOC
      See Also:

    • FETCH_MIN_BYTES_CONFIG

      public static final String FETCH_MIN_BYTES_CONFIG
      fetch.min.bytes
      See Also:

    • DEFAULT_FETCH_MIN_BYTES

      public static final int DEFAULT_FETCH_MIN_BYTES
      See Also:

    • FETCH_MAX_BYTES_CONFIG

      public static final String FETCH_MAX_BYTES_CONFIG
      fetch.max.bytes
      See Also:

    • DEFAULT_FETCH_MAX_BYTES

      public static final int DEFAULT_FETCH_MAX_BYTES
      See Also:

    • FETCH_MAX_WAIT_MS_CONFIG

      public static final String FETCH_MAX_WAIT_MS_CONFIG
      fetch.max.wait.ms
      See Also:

    • DEFAULT_FETCH_MAX_WAIT_MS

      public static final int DEFAULT_FETCH_MAX_WAIT_MS
      See Also:

    • METADATA_MAX_AGE_CONFIG

      public static final String METADATA_MAX_AGE_CONFIG
      metadata.max.age.ms
      See Also:

    • MAX_PARTITION_FETCH_BYTES_CONFIG

      public static final String MAX_PARTITION_FETCH_BYTES_CONFIG
      max.partition.fetch.bytes
      See Also:

    • DEFAULT_MAX_PARTITION_FETCH_BYTES

      public static final int DEFAULT_MAX_PARTITION_FETCH_BYTES
      See Also:

    • SEND_BUFFER_CONFIG

      public static final String SEND_BUFFER_CONFIG
      send.buffer.bytes
      See Also:

    • RECEIVE_BUFFER_CONFIG

      public static final String RECEIVE_BUFFER_CONFIG
      receive.buffer.bytes
      See Also:

    • CLIENT_ID_CONFIG

      public static final String CLIENT_ID_CONFIG
      client.id
      See Also:

    • CLIENT_RACK_CONFIG

      public static final String CLIENT_RACK_CONFIG
      client.rack
      See Also:

    • DEFAULT_CLIENT_RACK

      public static final String DEFAULT_CLIENT_RACK
      See Also:

    • RECONNECT_BACKOFF_MS_CONFIG

      public static final String RECONNECT_BACKOFF_MS_CONFIG
      reconnect.backoff.ms
      See Also:

    • RECONNECT_BACKOFF_MAX_MS_CONFIG

      public static final String RECONNECT_BACKOFF_MAX_MS_CONFIG
      reconnect.backoff.max.ms
      See Also:

    • RETRY_BACKOFF_MS_CONFIG

      public static final String RETRY_BACKOFF_MS_CONFIG
      retry.backoff.ms
      See Also:

    • METRICS_SAMPLE_WINDOW_MS_CONFIG

      public static final String METRICS_SAMPLE_WINDOW_MS_CONFIG
      metrics.sample.window.ms
      See Also:

    • METRICS_NUM_SAMPLES_CONFIG

      public static final String METRICS_NUM_SAMPLES_CONFIG
      metrics.num.samples
      See Also:

    • METRICS_RECORDING_LEVEL_CONFIG

      public static final String METRICS_RECORDING_LEVEL_CONFIG
      metrics.log.level
      See Also:

    • METRIC_REPORTER_CLASSES_CONFIG

      public static final String METRIC_REPORTER_CLASSES_CONFIG
      metric.reporters
      See Also:

    • AUTO_INCLUDE_JMX_REPORTER_CONFIG

      @Deprecated public static final String AUTO_INCLUDE_JMX_REPORTER_CONFIG
      Deprecated.
      auto.include.jmx.reporter
      See Also:

    • CHECK_CRCS_CONFIG

      public static final String CHECK_CRCS_CONFIG
      check.crcs
      See Also:

    • KEY_DESERIALIZER_CLASS_CONFIG

      public static final String KEY_DESERIALIZER_CLASS_CONFIG
      key.deserializer
      See Also:

    • KEY_DESERIALIZER_CLASS_DOC

      public static final String KEY_DESERIALIZER_CLASS_DOC
      See Also:

    • VALUE_DESERIALIZER_CLASS_CONFIG

      public static final String VALUE_DESERIALIZER_CLASS_CONFIG
      value.deserializer
      See Also:

    • VALUE_DESERIALIZER_CLASS_DOC

      public static final String VALUE_DESERIALIZER_CLASS_DOC
      See Also:

    • SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG

      public static final String SOCKET_CONNECTION_SETUP_TIMEOUT_MS_CONFIG
      socket.connection.setup.timeout.ms
      See Also:

    • 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:

    • CONNECTIONS_MAX_IDLE_MS_CONFIG

      public static final String CONNECTIONS_MAX_IDLE_MS_CONFIG
      connections.max.idle.ms
      See Also:

    • REQUEST_TIMEOUT_MS_CONFIG

      public static final String REQUEST_TIMEOUT_MS_CONFIG
      request.timeout.ms
      See Also:

    • DEFAULT_API_TIMEOUT_MS_CONFIG

      public static final String DEFAULT_API_TIMEOUT_MS_CONFIG
      default.api.timeout.ms
      See Also:

    • INTERCEPTOR_CLASSES_CONFIG

      public static final String INTERCEPTOR_CLASSES_CONFIG
      interceptor.classes
      See Also:

    • INTERCEPTOR_CLASSES_DOC

      public static final String INTERCEPTOR_CLASSES_DOC
      See Also:

    • EXCLUDE_INTERNAL_TOPICS_CONFIG

      public static final String EXCLUDE_INTERNAL_TOPICS_CONFIG
      exclude.internal.topics
      See Also:

    • DEFAULT_EXCLUDE_INTERNAL_TOPICS

      public static final boolean DEFAULT_EXCLUDE_INTERNAL_TOPICS
      See Also:

    • ISOLATION_LEVEL_CONFIG

      public static final String ISOLATION_LEVEL_CONFIG
      isolation.level
      See Also:

    • ISOLATION_LEVEL_DOC

      public static final String ISOLATION_LEVEL_DOC
      See Also:

    • 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:

    • DEFAULT_ALLOW_AUTO_CREATE_TOPICS

      public static final boolean DEFAULT_ALLOW_AUTO_CREATE_TOPICS
      See Also:

    • SECURITY_PROVIDERS_CONFIG

      public static final String SECURITY_PROVIDERS_CONFIG
      security.providers
      See Also:

  • Constructor Details

    • ConsumerConfig

      public ConsumerConfig(Properties props)

    • ConsumerConfig

      public ConsumerConfig(Map<String,Object> props)

    • ConsumerConfig

      protected ConsumerConfig(Map<?,?> props, boolean doLog)

  • Method Details

    • postProcessParsedConfig

      protected Map<String,Object> postProcessParsedConfig(Map<String,Object> parsedValues)
      Description copied from class: AbstractConfig
      Called directly after user configs got parsed (and thus default values got set). This allows to change default values for "secondary defaults" if required.
      Overrides:
      postProcessParsedConfig in class AbstractConfig
      Parameters:
      parsedValues - unmodifiable map of current configuration
      Returns:
      a map of updates that should be applied to the configuration (will be validated to prevent bad updates)

    • appendDeserializerToConfig

      protected static Map<String,Object> appendDeserializerToConfig(Map<String,Object> configs, Deserializer<?> keyDeserializer, Deserializer<?> valueDeserializer)

    • configNames

      public static Set<String> configNames()

    • configDef

      public static ConfigDef configDef()

    • main

      public static void main(String[] args)