Displaying 1 to 10 from 10 results

librdkafka - The Apache Kafka C/C++ library

  •    C

Copyright (c) 2012-2016, Magnus Edenhill.librdkafka is a C library implementation of the Apache Kafka protocol, containing both Producer and Consumer support. It was 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.

kq - Kafka-based Job Queue for Python

  •    Python

KQ (Kafka Queue) is a lightweight Python library which lets you queue and execute jobs asynchronously using Apache Kafka. It uses kafka-python under the hood. You may need to use sudo depending on your environment.

racecar - Racecar: a simple framework for Kafka consumers in Ruby

  •    Ruby

Using ruby-kafka directly can be a challenge: it's a flexible library with lots of knobs and options. Most users don't need that level of flexibility, though. Racecar provides a simple and intuitive way to build and configure Kafka consumers that optionally integrates seamlessly with Rails.This will add a config file in config/racecar.yml.




rafka - Interact with Kafka in a simple way

  •    Go

Rafka is a gateway service that exposes Kafka using simple semantics. It implements the Redis protocol.

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.

reactive-interaction-gateway - Your UI deserves an API, too!

  •    Elixir

In short: handling asynchronous events. Instead, let RIG handle those connections for you. RIG is designed for scalability and allows you to concentrate on the actual business logic. Back-end (micro)services no longer have to care about connection state, which means they can be stateless, making it very easy to roll out updates to them. Sending notifications to all online devices of a certain user becomes as easy as POSTing a message to an HTTP endpoint.


kafka-0.11-examples - Code snippets that demonstrate how to leverage the new Kafka 0.11 APIs

  •    Scala

This repository contains code snippets in Scala, using the Java clients, that demonstrate how to use the Kafka 0.11 new APIs. The code is incomplete, and that's intended: the goal is to bring the focus on the new APIs only.

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".