KafkaBatcher.TempStorage.Batch (kafka_batcher v1.1.1)

The struct used for KafkaBatcher.Behaviours.TempStorage behavior

Summary

Types

message()

t()

Types

message()

@type message() :: KafkaBatcher.MessageObject.t()

t()

@type t() :: %KafkaBatcher.TempStorage.Batch{
  messages: [message()],
  partition: String.t() | nil,
  producer_config: Keyword.t(),
  topic: String.t()
}