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