Rig.KafkaConsumerSetup (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

Boiler plate for initializing a Kafka client from RIG's configuration values.

Callbacks

Inspect the start-up configuration, make changes, or abort starting the consumer:

@spec validate(config :: map) :: {:ok, map} | :abort

React to incoming messages:

@spec kafka_handler(message :: String.t(), headers:: [{String.t(), String.t()}]) :: :ok | error :: any