A High Performance Cluster Consumer for Kafka that creates Avro (boom) files in Hadoop in time based directory paths - View it on GitHub