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

Performance-oriented stream processing built on Kafka and Zookeeper