GlassOctopus provides a minimal, modular and adaptable interface for developing Kafka consumers in Ruby. In its philosophy it is very close to Rack.

Json web token, setting data to header

A simple Kafka management UI.

Instruments the ruby-kafka gem for opentracing

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

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.