Kaffe.Producer (Kaffe v1.28.0)

The producer pulls in values from the Kaffe producer configuration. See Kaffe.Config.Producer for a list of options.

Clients can also specify a partition directly when producing.

Currently only synchronous production is supported.

Summary

headers()

Headers represent a list of tuples containing key, value pairs of type binary()

message()

A Kafka message can be represented as a tuple containing a key value pair of type binary()

message_object()

A Kafka message can also be represented as a map, containing :key, :value, and :headers

Synchronously produce the messages_list to topic

Synchronously produce the message_list to topic

Synchronously produce the message_list to topic/partition

Synchronously produce the given key/value to the topic/partition

@type headers() :: [{key :: binary(), value :: binary()}]

Headers represent a list of tuples containing key, value pairs of type binary()

@type message() :: {key :: binary(), value :: binary()}

A Kafka message can be represented as a tuple containing a key value pair of type binary()

@type message_object() :: %{
  key: key :: binary(),
  value: value :: binary(),
  headers: headers :: headers()
}

A Kafka message can also be represented as a map, containing :key, :value, and :headers

Synchronously produce the messages_list to topic

messages_list must be a list of type message() or message_object()
opts may include the partition strategy to use, partition_strategy: :md5, or :random or a function.

Returns:

 * `:ok` on successfully producing each message
 * `{:error, reason}` for any error

Synchronously produce the message_list to topic

messages must be a list of type message() or message_object()

Alternatively, synchronously produce the given key/value to the first Kafka topic.

This is a simpler way to produce if you've only given Producer a single topic for production and don't want to specify the topic for each call.

Returns:

 * `:ok` on successfully producing each message
 * `{:error, reason}` for any error

Synchronously produce the message_list to topic/partition

message_list must be a list of type message() or message_object()

Alternatively, synchronously produce the key/value to topic

Returns:

 * `:ok` on successfully producing each message
 * `{:error, reason}` for any error

Synchronously produce the given key/value to the topic/partition

See produce_sync/2 for returns.