Remove bad debug statement.
Add work on Kafka Consumer for 0.8
Add infrastructure for new consumer support.
Update Consumer to use BrokerChannel.
Make console consumer cleaner.
Clean up and update some tests.