Library to increase the throughput of producing messages (coming one at a time) to Kafka by accumulating these messages into batches

TasKafka is a background processing application written in Elixir and uses Kafka as a messaging backend.

build microservices with Kafka + Avro schemas

A general purpose messaging utility library supporting Exq and Kaffe

Framework for consuming Kafka events

An unofficial set of helper utilities for KafkaEx

Elixir logger that serializes to JSON and publish it to Apache Kafka

A MySQL to Kafka data pump

A wrapper around KafkaEx so you can mock it in test.

Consumer for Kafka using brod

KafkaEx Mock