Kayrock.MessageSet.Message (kayrock v0.1.15) View Source

Represents a single message with the v0 or v1 format

This is the old format that KafkaEx supported

See https://kafka.apache.org/documentation/#recordbatch

Link to this section Summary

Types

t()

Link to this section Types

t()

Specs

t() :: %Kayrock.MessageSet.Message{
  attributes: term(),
  compression: term(),
  crc: term(),
  key: term(),
  offset: term(),
  timestamp: term(),
  timestamp_type: term(),
  value: term()
}