Rig.KafkaConfig (Reactive Interaction Gateway v3.0.0-alpha.2) View Source
Boiler plate for initializing Kafka client configuration.
Link to this section Summary
Functions
Create a Kafka configuration map from given parameters.
Link to this section Functions
Create a Kafka configuration map from given parameters.
Note that brokers
is the only required parameter.
Example
iex> __MODULE__.parse(%{brokers: ["localhost:9092"]})
%RigKafka.Config{
brokers: [{"localhost", 9092}],
client_id: :"brod_client_cc25589c-4180-4f5d-93bf-b4fa778892b4",
consumer_topics: [],
group_id: nil,
sasl: nil,
schema_registry_host: nil,
serializer: nil,
server_id: :"rig_kafka_cc25589c-4180-4f5d-93bf-b4fa778892b4",
ssl: nil
}