Kaffe v1.17.0 Kaffe.Config.Consumer View Source

Link to this section Summary

Functions

async_message_ack()

begin_offset()

client_consumer_config()

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

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