Displaying 1 to 15 from 15 results

kafka-node - Node.js client for Apache Kafka 0.8 and later.

  •    Javascript

Kafka-node is a Node.js client with Zookeeper integration for Apache Kafka 0.8.1 and later. Follow the instructions on the Kafka wiki to build Kafka 0.8 and get a test broker up and running.

confluent-kafka-go - Confluent's Apache Kafka Golang client

  •    Go

confluent-kafka-go is Confluent's Golang client for Apache Kafka and the Confluent Platform.High performance - confluent-kafka-go is a lightweight wrapper around librdkafka, a finely tuned C client.

sqs-producer - Simple scaffolding for applications that produce SQS messages

  •    Javascript

Simple scaffolding for applications that produce SQS messages




kinesis-producer - An aggregated records producer for Amazon Kinesis

  •    Go

A KPL-like batch producer for Amazon Kinesis built on top of the official Go AWS SDK and using the same aggregation format that KPL use.

kafka-influxdb - High performance Kafka consumer for InfluxDB. Supports collectd message formats.

  •    Python

A Kafka consumer for InfluxDB written in Python. Supports InfluxDB 0.9.x and up. For InfluxDB 0.8.x support, check out the 0.3.0 tag. Kafka will serve as a buffer for your metric data during high load. Also it's useful for sending metrics from offshore data centers with unreliable connections to your monitoring backend.

redisq - RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis

  •    Java

RedisQ - Java implementation of a reliable Pub/Sub message queue based on Redis

borges - borges collects and stores Git repositories.

  •    Go

borges collects and stores Git repositories. I have always imagined that Paradise will be a kind of library.


kinesis-streams - AWS Kinesis readable and writable streams

  •    Javascript

There once was a Kinesis readable stream without a home, and a Kinesis writable stream without a home, so now they're roommates. NOTE: Kinesis was a bad idea, and we're switching to Kafka. So I won't be using my own library for much longer.

frizzle - The magic message bus

  •    Go

Frizzle is a magic message (Msg) bus designed for parallel processing with many goroutines. Start with the example implementation which shows a simple canonical implementation of a Processor on top of Frizzle and most of the core functions.

amqplib-rpc - Thin Amplib utils for RabbitMQ RPC in Node.js

  •    Javascript

Thin Amplib utils for RabbitMQ RPC in Node.js. Uses replyTo and correlationId message properties as the RabbitMQ rpc tutorial suggests. Make an rpc request, publish a message to an rpc queue.

erlkaf - Erlang kafka driver based on librdkafka

  •    Erlang

The library is implemented in top of librdkafka which is a C library implementation of the Apache Kafka protocol designed with message delivery reliability and high performance in mind, current figures exceed 1 million msgs/second for the producer and 3 million msgs/second for the consumer. It's well known that NIF's can affect the Erlang schedulers performances in case the functions are not returning in less than 1-2 ms and blocks the scheduler threads.

kafkabridge - The Apache Kafka Client SDK

  •    C++

Navigate to the cxx/c installation directory,and run build.sh -release, you will get a new file named libqbus.so in the "./lib/release" directory. Navigate to the Go installation directory,and run build.sh, you will get the new files qbus.go and libQBus_go.so in the directory "gopath/src/qbus".

grete - kafka client with threads and a scheduler

  •    Clojure

is gregor's sister that adds a threadpool and a scheduler






We have large collection of open source products. Follow the tags from Tag Cloud >>


Open source products are scattered around the web. Please provide information about the open source projects you own / you use. Add Projects.