userver: consumer_component
Loading...
Searching...
No Matches
consumer_component
Name Description Default value
group_id Consumer group id. Topic partition evenly distributed between consumers with the same group_id.
client_id Client identifier. May be an arbitrary string. Optional, but you should set this property on each instance because it enables you to more easily correlate requests on the broker with the client instance which made it, which can be helpful in debugging and troubleshooting scenarios. userver
topics.[] List of topics consumer subscribes. Each of the elements: topic name.
max_batch_size Maximum number of messages consumer waits for new messages before calling a callback. 1
poll_timeout Maximum amount of time consumer waits for new messages before calling a callback. 1s
message_key_log_format Specifies the logging format for the message key. - 'plaintext': logs the message key as-is. - 'hex': logs the message key in hexadecimal format. Possible values: plaintext, hex. plaintext
max_callback_duration Duration user callback must fit not to be kicked from the consumer group. The duration must fit in [1ms; 86400000ms]. 5m
restart_after_failure_delay Backoff consumer waits until restart after user-callback exception. 10s
auto_offset_reset Action to take when there is no initial offset in offset store or the desired offset is out of range: smallest, earliest, beginning - automatically reset the offset to the smallest offset largest, latest, end - automatically reset the offset to the largest offset, error - trigger an error (ERR__AUTO_OFFSET_RESET). Note: the policy applies iff there are not committed offsets in topic. Possible values: smallest, earliest, beginning, largest, latest, end, error.
env_pod_name If defined and group_id value contains {pod_name} substring, the substring is replaced with the value of the environment variable env_pod_name. none
security_protocol Protocol used to communicate with brokers. Possible values: PLAINTEXT, SASL_SSL, SASL_PLAINTEXT, SSL.
sasl_mechanisms SASL mechanism to use for authentication. Must be set if security_protocol equals SASL_SSL. Possible values: PLAIN, SCRAM-SHA-512. none
ssl_ca_location File or directory path to CA certificate(s) for verifying the broker's key. Must be set if security_protocol equals SASL_SSL or SSL. If set to probe, CA certificates are probed from the default certificates paths. none
topic_metadata_refresh_interval Period of time at which topic and broker metadata is refreshed in order to discover any new brokers, topics, partitions or partition leader changes. 5m
metadata_max_age Metadata cache max age. Recommended value is 3 times topic_metadata_refresh_interval. 15m
rd_kafka_custom_options.* A map of arbitrary librdkafka library configuration options. Full list of options is available by link: https://github.com/confluentinc/librdkafka/blob/master/CONFIGURATION.md. Note: This options is not guaranteed to be supported in userver-kafka, use it at your own risk. Each of the elements: librdkafka option value. {}
debug_info_log_level Log level for everything debug information. debug
operation_log_level Log level for infos about ordinary actions. debug