This gem is a Logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/logstash-plugin install gemname. This gem is not a stand-alone program

Kafka support for FFWD.

Cluster extensions for Poseidon, a producer and consumer implementation for Kafka >= 0.8

Aggregate log file events and send them elsewhere.

High-level consumer for Kafka. Implements the Zookeeper-backed consumer implementation that offers offset management, load balancing and automatic failovers.

Non Community Sensu plugins for Kafka

Performance-oriented stream processing built on Kafka and Zookeeper

Publish Avro files to Kafka in JSON format

Event bus adapter for Citrus.

interface to the rdkafka C library

Gelf deamon what sends events to kafka

Kafa ETL Base

A buffered log backed by Apache Kafka.

When mail is sent from your application, kafka_mailer will put the message contents in a kafka queue.

Sends a message to kafka whenever an active record instance is created, updated and/or removed.

This application was written because of a need for a tail-like way to consume Kafka messages. kafka-console-consumer.sh, which is distributed with Kafka, allows you to either read all messages in a topic, or any new message. However, most often I want to to see the most recent few messages from a...

MExiCo is a library and API for the management of multimodal experimental corpora.

Ruby Kafka Sidekiq

Kafka support for Ruby Object Mapper

Write Kafka consumers in a model with retry