Fluentd plugin for Apache Kafka > 0.8

Framework used to simplify Apache Kafka based Ruby applications development

A simple way to produce messages to Kafka from Ruby applications

RubyKafka instrumentation for the OpenTelemetry framework

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.

Phobos is a microframework and library for kafka based applications, it wraps common behaviors needed by consumers/producers in an easy an convenient API. It uses ruby-kafka as its kafka client and core component.

https://github.com/bsm/bps

Kafka libraries for Ruby.

Manage basic framework configurations.

This gem defines a way for Rails service or other backends to \ define a mailer that sends email to our employemt hero mail service.

A framework for doing cross app testing with support for distributed factories, test parallelism, and verification of async events.

Ruby client for reading from and writing to Druid.

This library publishes tracked ActiveRecord changes to a persistence layer such as Apache Kafka.

Farmstead is a modular data pipeline platform. Farmstead makes creating and deploying a fully-functional data pipeline a snap. Farmstead uses containers to encapsulate the middleware which allows for a super-fast deployment and prototyping process.

Fluentd plugin to send deis-router metricsto influxdb through kafka

Kafka client Plugin which supports version 0.9 of kafka.

Fluentd plugin for Apache Kafka > 0.8

Kafka's produce fluentd plugin by ruby-kafka

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