Produce & consume Kafka messages in traceable sessions.

Makes producing and consuming topics simple. Useful when experimenting.

Fluentd

A library for decoupling applications by using messaging to communicate between components.

This contains all the code for using phobos in a ruby project

This aims to be a common benchmark tool for MOM

Octocore is the core framework of Octomatic Enterprise. It contains all the core models, tasks, actions etc.

Octocore is the core framework of Octomatic Enterprise. It contains all the core models, tasks, actions etc for Cassandra

Octocore is the core framework of Octomatic Enterprise. It contains all the core models, tasks, actions etc for MongoDB

Framework to automate responses for infrastructure events. Ocular allows to easily create small scripts which are triggered from multiple different event sources and which can then execute scripts commanding all kinds of infrastructure, do remote command execution, execute AWS API calls, modify ...

Client to broadcast and log.

Ruby Kafka Sidekiq

Fluentd plugin for Apache Kafka > 0.8

Kafka::EC2 is an extension of ruby-kafka that provides useful features for EC2 like Kafka::EC2::MixedInstanceAssignmentStrategy.

The RubyKafkaRetry gem provides a mechanism to handle message retries and dead-letter queue (DLQ) functionality in Ruby applications using Kafka. It ensures messages are retried with an increasing delay before being sent to a DLQ.

Let me crash here for a moment.

Extends Yabeda metrics to collect ruby-kafka metrics

Kafka with using Zookeeper as the cluster manager