View Source Kayrock.MessageSet (kayrock v0.2.0-rc.1)

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

Summary

Types

t()

Functions

deserialize(data)
deserialize(data, magic)
serialize(message_set)

Types

Link to this type

t()

View Source 
@type t() :: %Kayrock.MessageSet{magic: term(), messages: term()}

Functions

Link to this function

deserialize(data)

View Source 
@spec deserialize(binary()) :: t()
Link to this function

deserialize(data, magic)

View Source
Link to this function

serialize(message_set)

View Source 
@spec serialize(t()) :: iodata()