brook v0.6.0 Brook.Driver.Kafka
Implements the Brook.Driver
behaviour for using Kafka
as the message bus underlying the event stream.
Brook's Kafka driver uses the (Elsa)[https://github.com/bbalser/elsa] library for subscribing to and sending messages to a Kafka topic handling event stream communication between distributed applications.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Initialize the Elsa supervision tree for the consumer of the event stream topic.
Send Brook event messages to the event stream topic.
Start Brook.Driver
and link to the current process
Link to this section Functions
child_spec(init_arg)
Returns a specification to start this module under a supervisor.
See Supervisor
.
init(init_arg)
Initialize the Elsa supervision tree for the consumer of the event stream topic.
send_event(instance, type, message)
Send Brook event messages to the event stream topic.
start_link(args)
Start Brook.Driver
and link to the current process