View Source KafkaEx.Protocol.Produce.Message (kafka_ex v0.13.0)

key: is used for partition assignment, can be nil, when none is provided it is defaulted to nil
value: is the message to be written to Kafka logs.
headers: is a list of keys and values that adds metadata to messages
timestamp: timestamp (kafka_version: "kayrock" ONLY)

Link to this section Summary

Types

t()

Link to this section Types

t()

@type t() :: %KafkaEx.Protocol.Produce.Message{
  headers: [{key :: binary(), value :: binary()}],
  key: binary(),
  timestamp: integer(),
  value: binary()
}