Kaffe
v1.25.0
Pages
Modules
Kaffe.Config.Consumer
(Kaffe v1.25.0)
View Source
Link to this section
Summary
Functions
async_message_ack()
begin_offset()
client_consumer_config()
client_down_retry_expire()
config_get(key, default)
config_get!(key)
configuration()
consumer_group()
consumer_group_config()
default_client_consumer_config()
endpoints()
heroku_kafka?()
max_bytes()
max_wait_time()
maybe_heroku_kafka_ssl()
message_handler()
min_bytes()
offset_reset_policy()
rebalance_delay_ms()
sasl_options()
ssl_options()
subscriber_name()
subscriber_retries()
subscriber_retry_delay_ms()
topics()
worker_allocation_strategy()
Link to this section
Functions
Link to this function
async_message_ack()
View Source
Link to this function
begin_offset()
View Source
Link to this function
client_consumer_config()
View Source
Link to this function
client_down_retry_expire()
View Source
Link to this function
config_get(key, default)
View Source
Link to this function
config_get!(key)
View Source
Link to this function
configuration()
View Source
Link to this function
consumer_group()
View Source
Link to this function
consumer_group_config()
View Source
Link to this function
default_client_consumer_config()
View Source
Link to this function
endpoints()
View Source
Link to this function
heroku_kafka?()
View Source
Link to this function
max_bytes()
View Source
Link to this function
max_wait_time()
View Source
Link to this function
maybe_heroku_kafka_ssl()
View Source
Link to this function
message_handler()
View Source
Link to this function
min_bytes()
View Source
Link to this function
offset_reset_policy()
View Source
Link to this function
rebalance_delay_ms()
View Source
Link to this function
sasl_options()
View Source
Link to this function
ssl_options()
View Source
Link to this function
subscriber_name()
View Source
Link to this function
subscriber_retries()
View Source
Link to this function
subscriber_retry_delay_ms()
View Source
Link to this function
topics()
View Source
Link to this function
worker_allocation_strategy()
View Source