consumer refactoring
consumer refactoring
consumer refactoring
Consumer refactoring
updating code to accommodate the latest changes in kafka 0.8
cleaning up