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
}