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.
154 stars
18 watching
62 forks
Language: Elixir
last commit: 30 days ago
Linked from 1 awesome list
elixirkafka
Related projects:
Repository | Description | Stars |
---|---|---|
kafka4beam/brod | An Erlang implementation of the Apache Kafka protocol for producing and consuming messages in a distributed system. | 662 |
kafka4beam/kafka_protocol | A Kafka protocol library for Erlang/Elixir, providing basic connection management APIs and utility functions. | 95 |
kafkaex/kafka_ex | An Elixir client for Apache Kafka with support for various features and a planned upgrade to a cleaner API | 598 |
allegro/hermes | A message broker built on top of Kafka for reliable and fault-tolerant communication | 819 |
obsidiandynamics/meteor | Enables real-time message streaming over an in-memory data grid for high-volume, low-latency distribution among decoupled processes. | 23 |
jdamick/kafka | A Go implementation of a distributed publish-subscribe messaging system | 130 |
tamediadigital/librdkafka-d | An object-oriented wrapper around the librdkafka C library for messaging system integration. | 11 |
bt-opensource/crafka | A Crystal library for interacting with Apache Kafka message brokers | 17 |
php-kafka/php-simple-kafka-client | A PHP extension that provides a simple interface to produce and consume data in real-time messaging systems like Kafka and Redpanda. | 27 |
didier-wenzek/ocaml-kafka | Bindings for a distributed messaging system used for asynchronous data exchange between applications. | 63 |
cyngn/vertx-kafka | A multi-threaded worker library that consumes Kafka messages and re-broadcasts them on the Vert.x event bus. | 30 |
silviucpp/erlkaf | An Erlang driver for interacting with Apache Kafka using librdkafka | 85 |
cafxx/kafkabalancer | Automates rebalancing of Kafka clusters to minimize workload difference between brokers. | 48 |
reiseburo/hermann | A Ruby gem providing cross-platform Kafka producer and consumer support using various runtime environments. | 71 |
mre/kafka-influxdb | A Kafka consumer for InfluxDB that buffers metric data during high loads and enables reliable sending of metrics from remote locations. | 216 |