kaffe
Message broker
An Elixir wrapper around the Erlang Kafka client for producing and consuming messages in a scalable manner.
An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.
155 stars
19 watching
63 forks
Language: Elixir
last commit: 4 months ago
Linked from 1 awesome list
elixirkafka
Related projects:
Repository | Description | Stars |
---|---|---|
| An Erlang implementation of the Apache Kafka protocol for producing and consuming messages in a distributed system. | 666 |
| A Kafka protocol library for Erlang/Elixir, providing basic connection management APIs and utility functions. | 95 |
| An Elixir client for Apache Kafka with support for various features and a planned upgrade to a cleaner API | 599 |
| A message broker built on top of Kafka for reliable and fault-tolerant communication | 820 |
| Enables real-time message streaming over an in-memory data grid for high-volume, low-latency distribution among decoupled processes. | 23 |
| A Go implementation of a distributed publish-subscribe messaging system | 129 |
| An object-oriented wrapper around the librdkafka C library for messaging system integration. | 11 |
| A Crystal library for interacting with Apache Kafka message brokers | 17 |
| A PHP extension that provides a simple interface to produce and consume data in real-time messaging systems like Kafka and Redpanda. | 27 |
| Bindings for a distributed messaging system used for asynchronous data exchange between applications. | 63 |
| A multi-threaded worker library that consumes Kafka messages and re-broadcasts them on the Vert.x event bus. | 30 |
| An Erlang driver for interacting with Apache Kafka using librdkafka | 85 |
| Automates rebalancing of Kafka clusters to minimize workload difference between brokers. | 48 |
| A Ruby gem providing cross-platform Kafka producer and consumer support using various runtime environments. | 71 |
| A Kafka consumer for InfluxDB that buffers metric data during high loads and enables reliable sending of metrics from remote locations. | 216 |