Main interface for consumer
An iterator that blocks until a value can be read from the supplied queue.
All calls to elements should produce the same thread-safe iterator? Should have a seperate thread that feeds messages into a blocking queue for processing.
A consumer of kafka messages
JMX interface for monitoring consumer
Consumer that dumps messages out to standard out.