KafkaBatcher.MessageObject (kafka_batcher v1.1.1)

Contains Kafka message fields

Fields

:key - Kafka use it for partitioning
:value - the main payload of the message
:headers - a keyword list with auxiliary key-value pairs

Summary

Types

t()

Types

t()

@type t() :: %KafkaBatcher.MessageObject{
  headers: list(),
  key: binary(),
  value: map() | binary()
}