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

Kafka client for RIG.

Basically wrapping :brod, tailored to our needs.

Link to this section Summary

Functions

produce(config, topic, schema, key, plaintext)

See RigKafka.Client.produce/5.

produce(config, topic, schema, key, plaintext, headers)

See RigKafka.Client.produce/6.

start(config, callback \\ nil)

See RigKafka.Client.start_supervised/2.

Link to this section Functions

produce(config, topic, schema, key, plaintext)

See RigKafka.Client.produce/5.

produce(config, topic, schema, key, plaintext, headers)

Specs

produce(RigKafka.Config.t(), topic(), schema(), key(), plaintext(), headers()) ::
  :ok

See RigKafka.Client.produce/6.

start(config, callback \\ nil)

Specs

start(RigKafka.Config.t(), RigKafka.Client.callback() | nil) ::
  {:ok, pid()} | :ignore | {:error, any()}

See RigKafka.Client.start_supervised/2.