Kaffe.Config.Consumer (Kaffe v1.27.2)

View Source

Summary

Functions

async_message_ack(config_key)
begin_offset(config_key)
client_consumer_config(config_key)
client_down_retry_expire(config_key)
config_get(config_key, key, default)
config_get!(config_key, key)
configuration(config_key)
consumer_group(config_key)
consumer_group_config(config_key)
default_client_consumer_config(config_key)
endpoints(config_key)
heroku_kafka?(config_key)
max_bytes(config_key)
max_wait_time(config_key)
maybe_heroku_kafka_ssl(config_key)
message_handler(config_key)
min_bytes(config_key)
offset_reset_policy(config_key)
rebalance_delay_ms(config_key)
sasl_options(config_key)
ssl_options(config_key)
subscriber_name(config_key)
subscriber_retries(config_key)
subscriber_retry_delay_ms(config_key)
topics(config_key)
validate_configuration!()
worker_allocation_strategy(config_key)

Functions

async_message_ack(config_key)

begin_offset(config_key)

client_consumer_config(config_key)

client_down_retry_expire(config_key)

config_get(config_key, key, default)

config_get!(config_key, key)

configuration(config_key)

consumer_group(config_key)

consumer_group_config(config_key)

default_client_consumer_config(config_key)

endpoints(config_key)

heroku_kafka?(config_key)

max_bytes(config_key)

max_wait_time(config_key)

maybe_heroku_kafka_ssl(config_key)

message_handler(config_key)

min_bytes(config_key)

offset_reset_policy(config_key)

rebalance_delay_ms(config_key)

sasl_options(config_key)

ssl_options(config_key)

subscriber_name(config_key)

subscriber_retries(config_key)

subscriber_retry_delay_ms(config_key)

topics(config_key)

validate_configuration!()

worker_allocation_strategy(config_key)