Package org.apache.kafka.clients.consumer

Class ConsumerConfig

  • public class ConsumerConfig
extends AbstractConfig
    The consumer configuration keys

    • Field Detail

      • GROUP_ID_CONFIG

        public static final java.lang.String GROUP_ID_CONFIG
        group.id
        See Also:
        Constant Field Values

      • GROUP_INSTANCE_ID_CONFIG

        public static final java.lang.String GROUP_INSTANCE_ID_CONFIG
        group.instance.id
        See Also:
        Constant Field Values

      • MAX_POLL_RECORDS_CONFIG

        public static final java.lang.String MAX_POLL_RECORDS_CONFIG
        max.poll.records
        See Also:
        Constant Field Values

      • MAX_POLL_INTERVAL_MS_CONFIG

        public static final java.lang.String MAX_POLL_INTERVAL_MS_CONFIG
        max.poll.interval.ms
        See Also:
        Constant Field Values

      • SESSION_TIMEOUT_MS_CONFIG

        public static final java.lang.String SESSION_TIMEOUT_MS_CONFIG
        session.timeout.ms
        See Also:
        Constant Field Values

      • HEARTBEAT_INTERVAL_MS_CONFIG

        public static final java.lang.String HEARTBEAT_INTERVAL_MS_CONFIG
        heartbeat.interval.ms
        See Also:
        Constant Field Values

      • BOOTSTRAP_SERVERS_CONFIG

        public static final java.lang.String BOOTSTRAP_SERVERS_CONFIG
        bootstrap.servers
        See Also:
        Constant Field Values

      • CLIENT_DNS_LOOKUP_CONFIG

        public static final java.lang.String CLIENT_DNS_LOOKUP_CONFIG
        client.dns.lookup
        See Also:
        Constant Field Values

      • ENABLE_AUTO_COMMIT_CONFIG

        public static final java.lang.String ENABLE_AUTO_COMMIT_CONFIG
        enable.auto.commit
        See Also:
        Constant Field Values

      • AUTO_COMMIT_INTERVAL_MS_CONFIG

        public static final java.lang.String AUTO_COMMIT_INTERVAL_MS_CONFIG
        auto.commit.interval.ms
        See Also:
        Constant Field Values

      • PARTITION_ASSIGNMENT_STRATEGY_CONFIG

        public static final java.lang.String PARTITION_ASSIGNMENT_STRATEGY_CONFIG
        partition.assignment.strategy
        See Also:
        Constant Field Values

      • AUTO_OFFSET_RESET_CONFIG

        public static final java.lang.String AUTO_OFFSET_RESET_CONFIG
        auto.offset.reset
        See Also:
        Constant Field Values

      • AUTO_OFFSET_RESET_DOC

        public static final java.lang.String AUTO_OFFSET_RESET_DOC
        See Also:
        Constant Field Values

      • FETCH_MIN_BYTES_CONFIG

        public static final java.lang.String FETCH_MIN_BYTES_CONFIG
        fetch.min.bytes
        See Also:
        Constant Field Values

      • FETCH_MAX_BYTES_CONFIG

        public static final java.lang.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 java.lang.String FETCH_MAX_WAIT_MS_CONFIG
        fetch.max.wait.ms
        See Also:
        Constant Field Values

      • METADATA_MAX_AGE_CONFIG

        public static final java.lang.String METADATA_MAX_AGE_CONFIG
        metadata.max.age.ms
        See Also:
        Constant Field Values

      • MAX_PARTITION_FETCH_BYTES_CONFIG

        public static final java.lang.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 java.lang.String SEND_BUFFER_CONFIG
        send.buffer.bytes
        See Also:
        Constant Field Values

      • RECEIVE_BUFFER_CONFIG

        public static final java.lang.String RECEIVE_BUFFER_CONFIG
        receive.buffer.bytes
        See Also:
        Constant Field Values

      • CLIENT_ID_CONFIG

        public static final java.lang.String CLIENT_ID_CONFIG
        client.id
        See Also:
        Constant Field Values

      • CLIENT_RACK_CONFIG

        public static final java.lang.String CLIENT_RACK_CONFIG
        client.rack
        See Also:
        Constant Field Values

      • RECONNECT_BACKOFF_MS_CONFIG

        public static final java.lang.String RECONNECT_BACKOFF_MS_CONFIG
        reconnect.backoff.ms
        See Also:
        Constant Field Values

      • RECONNECT_BACKOFF_MAX_MS_CONFIG

        public static final java.lang.String RECONNECT_BACKOFF_MAX_MS_CONFIG
        reconnect.backoff.max.ms
        See Also:
        Constant Field Values

      • RETRY_BACKOFF_MS_CONFIG

        public static final java.lang.String RETRY_BACKOFF_MS_CONFIG
        retry.backoff.ms
        See Also:
        Constant Field Values

      • METRICS_ENABLED_CONFIG

        public static final java.lang.String METRICS_ENABLED_CONFIG
        metrics.enabled
        See Also:
        Constant Field Values

      • METRICS_SAMPLE_WINDOW_MS_CONFIG

        public static final java.lang.String METRICS_SAMPLE_WINDOW_MS_CONFIG
        metrics.sample.window.ms
        See Also:
        Constant Field Values

      • METRICS_NUM_SAMPLES_CONFIG

        public static final java.lang.String METRICS_NUM_SAMPLES_CONFIG
        metrics.num.samples
        See Also:
        Constant Field Values

      • METRICS_RECORDING_LEVEL_CONFIG

        public static final java.lang.String METRICS_RECORDING_LEVEL_CONFIG
        metrics.log.level
        See Also:
        Constant Field Values

      • METRIC_REPORTER_CLASSES_CONFIG

        public static final java.lang.String METRIC_REPORTER_CLASSES_CONFIG
        metric.reporters
        See Also:
        Constant Field Values

      • CHECK_CRCS_CONFIG

        public static final java.lang.String CHECK_CRCS_CONFIG
        check.crcs
        See Also:
        Constant Field Values

      • KEY_DESERIALIZER_CLASS_CONFIG

        public static final java.lang.String KEY_DESERIALIZER_CLASS_CONFIG
        key.deserializer
        See Also:
        Constant Field Values

      • KEY_DESERIALIZER_CLASS_DOC

        public static final java.lang.String KEY_DESERIALIZER_CLASS_DOC
        See Also:
        Constant Field Values

      • VALUE_DESERIALIZER_CLASS_CONFIG

        public static final java.lang.String VALUE_DESERIALIZER_CLASS_CONFIG
        value.deserializer
        See Also:
        Constant Field Values

      • VALUE_DESERIALIZER_CLASS_DOC

        public static final java.lang.String VALUE_DESERIALIZER_CLASS_DOC
        See Also:
        Constant Field Values

      • CONNECTIONS_MAX_IDLE_MS_CONFIG

        public static final java.lang.String CONNECTIONS_MAX_IDLE_MS_CONFIG
        connections.max.idle.ms
        See Also:
        Constant Field Values

      • REQUEST_TIMEOUT_MS_CONFIG

        public static final java.lang.String REQUEST_TIMEOUT_MS_CONFIG
        request.timeout.ms
        See Also:
        Constant Field Values

      • DEFAULT_API_TIMEOUT_MS_CONFIG

        public static final java.lang.String DEFAULT_API_TIMEOUT_MS_CONFIG
        default.api.timeout.ms
        See Also:
        Constant Field Values

      • INTERCEPTOR_CLASSES_CONFIG

        public static final java.lang.String INTERCEPTOR_CLASSES_CONFIG
        interceptor.classes
        See Also:
        Constant Field Values

      • INTERCEPTOR_CLASSES_DOC

        public static final java.lang.String INTERCEPTOR_CLASSES_DOC
        See Also:
        Constant Field Values

      • STREAMS_RPC_TIMEOUT_MS_CONFIG

        public static final java.lang.String STREAMS_RPC_TIMEOUT_MS_CONFIG
        streams.rpc.timeout.ms
        See Also:
        Constant Field Values

      • STREAMS_HARDMOUNT_CONFIG

        public static final java.lang.String STREAMS_HARDMOUNT_CONFIG
        fs.mapr.hardmount
        See Also:
        Constant Field Values

      • STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG

        public static final java.lang.String STREAMS_CONSUMER_DEFAULT_STREAM_CONFIG
        streams.consumer.default.stream
        See Also:
        Constant Field Values

      • STREAMS_RECORD_STRIP_STREAMPATH_CONFIG

        public static final java.lang.String STREAMS_RECORD_STRIP_STREAMPATH_CONFIG
        streams.record.strip.streampath
        See Also:
        Constant Field Values

      • STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG

        public static final java.lang.String STREAMS_CONSUMER_BUFFER_MEMORY_CONFIG
        streams.consumer.buffer.memory
        See Also:
        Constant Field Values

      • STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG

        public static final java.lang.String STREAMS_ZEROOFFSET_RECORD_ON_EOF_CONFIG
        See Also:
        Constant Field Values

      • STREAMS_NEGATIVEOFFSET_RECORD_ON_EOF_CONFIG

        public static final java.lang.String STREAMS_NEGATIVEOFFSET_RECORD_ON_EOF_CONFIG
        See Also:
        Constant Field Values

      • STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_CONFIG

        public static final java.lang.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 java.lang.String STREAMS_DEFAULT_INTERNAL_STREAM_CONFIG
        streams.default.internal.stream
        See Also:
        Constant Field Values

      • EXCLUDE_INTERNAL_TOPICS_CONFIG

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

      • STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_INTERNAL_STREAM

        public static final java.lang.String STREAMS_CLIENTSIDE_PARTITION_ASSIGNMENT_INTERNAL_STREAM
        streams.clientside.partition.assignment
        See Also:
        Constant Field Values

      • ISOLATION_LEVEL_CONFIG

        public static final java.lang.String ISOLATION_LEVEL_CONFIG
        isolation.level
        See Also:
        Constant Field Values

      • ISOLATION_LEVEL_DOC

        public static final java.lang.String ISOLATION_LEVEL_DOC
        See Also:
        Constant Field Values

      • DEFAULT_ISOLATION_LEVEL

        public static final java.lang.String DEFAULT_ISOLATION_LEVEL

      • ALLOW_AUTO_CREATE_TOPICS_CONFIG

        public static final java.lang.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 java.lang.String SECURITY_PROVIDERS_CONFIG
        security.providers
        See Also:
        Constant Field Values

    • Constructor Detail

      • ConsumerConfig

        public ConsumerConfig​(java.util.Properties props)

      • ConsumerConfig

        public ConsumerConfig​(java.util.Map<java.lang.String,​java.lang.Object> props)

      • ConsumerConfig

        protected ConsumerConfig​(java.util.Map<?,​?> props,
                         boolean doLog)

    • Method Detail

      • postProcessParsedConfig

        protected java.util.Map<java.lang.String,​java.lang.Object> postProcessParsedConfig​(java.util.Map<java.lang.String,​java.lang.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)

      • addDeserializerToConfig

        public static java.util.Map<java.lang.String,​java.lang.Object> addDeserializerToConfig​(java.util.Map<java.lang.String,​java.lang.Object> configs,
                                                                                             Deserializer<?> keyDeserializer,
                                                                                             Deserializer<?> valueDeserializer)

      • addDeserializerToConfig

        public static java.util.Properties addDeserializerToConfig​(java.util.Properties properties,
                                                           Deserializer<?> keyDeserializer,
                                                           Deserializer<?> valueDeserializer)

      • configNames

        public static java.util.Set<java.lang.String> configNames()

      • configDef

        public static ConfigDef configDef()

      • main

        public static void main​(java.lang.String[] args)