elsa v0.12.3 Elsa.Message
Defines the structure of a Kafka message provided by the Elsa library and the function to construct the message struct.
Link to this section Summary
Functions
Constructs a message struct from the imported definition of a kafka_message as
defined by the brod library with the addition of the topic and partition the message
was read from as well as the optional generation id as defined by the message's relationship
to a consumer group. Generation id defaults to nil
in the event the message retrieved
outside of the context of a consumer group.
Link to this section Types
elsa_message()
elsa_message() :: %Elsa.Message{ generation_id: integer() | nil, headers: list(), key: term(), offset: integer(), partition: Elsa.partition(), timestamp: term(), topic: Elsa.topic(), value: term() }
kafka_message()
Link to this section Functions
Constructs a message struct from the imported definition of a kafka_message as
defined by the brod library with the addition of the topic and partition the message
was read from as well as the optional generation id as defined by the message's relationship
to a consumer group. Generation id defaults to nil
in the event the message retrieved
outside of the context of a consumer group.