Simple solution for organizing 2 way syncing between kafka clusters

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 databases and so on. The goal is that a new script could be written really quickly to automate a previously manual infrastructure maintenance job instead of doing the manual job yet another time. Scripts are written in Ruby with a simple Ocular DSL which allows the script to easily respond to multitude different events.

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