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

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

Ruby Kafka Sidekiq

Kafka support for Ruby Object Mapper

Write Kafka consumers in a model with retry

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

Watch and tail files with specified time based patterns and push them to kafka

Utility gem to stream teradata results out of the teradata data warehouse, supporting adaptors for various formats and destinations

Minimal Kafka runner suitable for integration testing