elsa v0.12.3 Elsa.Wrapper

Provides a supervisable wrapper for the Elsa supervision tree to manage brod producers and consumers. Provides convenience functions for starting producer and consumer processes directly without the default supervisors brod interposes between them and the application.

By taking over supervision of the processes directly interacting with Kafka by way of a brod client, these processes can be registered independently from the client process so in the event of the client dropping its connection, the record of what processes should be producing or consuming from what topics and partitions can be immediately reconstructed instead of being dropped.

Link to this section Summary

Functions

Returns a specification to start this module under a supervisor.

Callback implementation for GenServer.init/1.

Link to this section Functions

Link to this function

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

Callback implementation for GenServer.init/1.

Link to this function

start_link(args)