Kayrock.MessageSet (kayrock v0.1.15) View Source

Represents a set of messages 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

Link to this section Types

Specs

t() :: %Kayrock.MessageSet{magic: term(), messages: term()}

Link to this section Functions

Specs

deserialize(binary()) :: t()
Link to this function

deserialize(data, magic)

View Source

Specs

serialize(t()) :: iodata()