Reactive Interaction Gateway v3.0.0-alpha.2

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

The Kafka client that holds connections to one or more brokers.

Link to this section Summary

Types

callback()
kafka_headers()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

produce(map, topic, schema, key, plaintext)
produce(map, topic, schema, key, plaintext, headers)
start_link(opts)
start_supervised(config, callback \\ nil)
stop_supervised(client_pid)

Link to this section Types

Link to this type

callback()

View Source

Specs

callback() :: (any() -> :ok | any())
Link to this type

kafka_headers()

View Source

Specs

kafka_headers() :: list()

Link to this section Functions

Link to this function

child_spec(init_arg)

View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

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

View Source
Link to this function

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

View Source
Link to this function

start_link(opts)

View Source

Specs

start_link(list()) :: {:ok, pid()} | :ignore | {:error, any()}
Link to this function

start_supervised(config, callback \\ nil)

View Source

Specs

start_supervised(RigKafka.Config.t(), callback() | nil) ::
  {:ok, pid()} | :ignore | {:error, any()}
Link to this function

stop_supervised(client_pid)

View Source

Specs

stop_supervised(pid()) :: :ok | {:error, :not_found}