Cleanup.
Add additional integration tests and fix a whole bunch of concurrency issues.
Rename topic_consumer.go to consumer_example.go
Remove excessive logging.