kayrock v0.1.12

Kayrock.RecordBatch (kayrock v0.1.12) View Source

Represents a batch of records (also called a record set)

This is the newer format in Kafka 0.11+

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

Link to this section Summary

Types

t()

Functions

deserialize(record_batch_data)

Direct deserializer

deserialize(msg_set_size, msg_set_data)
from_binary_list(messages, compression \\ :none)
serialize(record_batch)

Link to this section Types

Link to this type

t()

View Source

Specs

t() :: %Kayrock.RecordBatch{
  attributes: term(),
  base_sequence: term(),
  batch_length: term(),
  batch_offset: term(),
  crc: term(),
  first_timestamp: term(),
  last_offset_delta: term(),
  max_timestamp: term(),
  partition_leader_epoch: term(),
  producer_epoch: term(),
  producer_id: term(),
  records: term()
}

Link to this section Functions

Link to this function

deserialize(record_batch_data)

View Source

Specs

deserialize(binary()) :: nil | Kayrock.MessageSet.t() | t()

Direct deserializer

Supplied for compatibility with the Request protocol

Link to this function

deserialize(msg_set_size, msg_set_data)

View Source

Specs

deserialize(integer(), binary()) :: nil | Kayrock.MessageSet.t() | t()
Link to this function

from_binary_list(messages, compression \\ :none)

View Source

Specs

from_binary_list([binary()], atom()) :: t()
Link to this function

serialize(record_batch)

View Source

Specs

serialize(t()) :: iodata()