KafkaBatcher.Collector.Utils (kafka_batcher v1.1.1)

Provides functions for transforming events in different input formats into MessageObject struct

Summary

Types

event()

Functions

prepare_events(events)
transform_event(event)

Types

event()

@type event() ::
  binary()
  | {binary(), binary()}
  | {list(), binary(), binary()}
  | map()
  | KafkaBatcher.MessageObject.t()

Functions

prepare_events(events)

@spec prepare_events([event()]) :: [KafkaBatcher.MessageObject.t()]

transform_event(event)

@spec transform_event(event()) :: KafkaBatcher.MessageObject.t()