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

  • 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.
  • timestamp: timestamp (kafka_version: "kayrock" ONLY)

Link to this section Summary

Link to this section Types


t() :: %KafkaEx.Protocol.Produce.Message{
  key: binary(),
  timestamp: integer(),
  value: binary()