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