An opinionated, highly specific, Elixir wrapper around brod: the Erlang Kafka client. :coffee

Consume messages from Kafka and pass to a given local module

Running state for the consumer

This is the main process for launching group members and workers

Consume messages from a Kafka topic for a consumer group

The top-level supervisor for group members and subscribers

The producer pulls in values from the Kaffe producer configuration

Consume messages from a single partition of a single Kafka topic

A worker is assigned a single partition across topics for the client. This is so we effectively serialize the processing of any single key across topics

Manage partition-to-worker assignments. Subscribers get workers from here

Supervise the individual workers