AltworxBook.Kafka.RawTopic (altworx_book v0.2.0)
Kafka raw topic interaction helper functions.
Link to this section Summary
Functions
Return message from topic with given offset.
List all raw topics.
Return list of messages from raw topic.
Link to this section Types
Link to this type
message()
@type message() :: %{timestamp: AltworxBook.Altworx.timestamp(), value: String.t()}
Link to this section Functions
Link to this function
get_message(topic_name, offset)
Return message from topic with given offset.
Link to this function
list()
@spec list() :: [String.t()]
List all raw topics.
Link to this function
list_messages(topic_name, since, count, config \\ [])
Return list of messages from raw topic.