KafkaBatcher.Config (kafka_batcher v1.1.1)

KafkaBatcher configuration processing. All config parameters are described in details in README.md Examples of configs can be found in the files config/test.exs and test/support/collectors/collector_handlers.ex

Summary

Types

sasl_mechanism()
sasl_type()

Functions

build_topic_config(opts)
collectors_spec()
general_producer_config()
get_collector_config(topic_name)
get_configs_by_collector!()
get_configs_by_topic_name()

Return all configured topics with its config.

get_endpoints()
get_endpoints(config)

Types

sasl_mechanism()

@type sasl_mechanism() :: :plain | :scram_sha_256 | :scram_sha_512

sasl_type()

@type sasl_type() :: {sasl_mechanism(), binary(), binary()} | :undefined

Functions

build_topic_config(opts)

@spec build_topic_config(opts :: Keyword.t()) :: Keyword.t()

collectors_spec()

@spec collectors_spec() :: [:supervisor.child_spec()]

general_producer_config()

@spec general_producer_config() :: Keyword.t()

get_collector_config(topic_name)

@spec get_collector_config(topic_name :: binary()) :: Keyword.t()

get_configs_by_collector!()

@spec get_configs_by_collector!() :: [{atom(), Keyword.t()}]

get_configs_by_topic_name()

@spec get_configs_by_topic_name() :: [{binary(), Keyword.t()}]

Return all configured topics with its config.

get_endpoints()

@spec get_endpoints() :: [{binary(), non_neg_integer()}]

get_endpoints(config)

@spec get_endpoints(config :: Keyword.t()) :: [{binary(), non_neg_integer()}]