mconsumer

mconsumer

Simple and naive kafka consumers which pulls data from multiple topics and writes to tcp sockets. This was originally written to use kafka as a queue for wrting metrics to graphite.

To Do

• Add logging
• Signal handling to flush in memory messages
• Metrics
• Allow configuration via file
• Better way to push out data