elsa v0.12.3 Elsa.Consumer
Public api to consumer acks asynchronously for simple consumers
Link to this section Summary
Functions
Retrieves a process id of a consumer registered to the Elsa Registry and performs a consume-ack of the messages ready to be read off the topic.
Link to this section Types
Link to this section Functions
Link to this function
ack(connection, topic, partition, offset)
ack(Elsa.connection(), Elsa.topic(), Elsa.partition(), offset()) :: :ok
Retrieves a process id of a consumer registered to the Elsa Registry and performs a consume-ack of the messages ready to be read off the topic.