Upgrade to kafka 0.8.1.1

updated
Merge pull request #6 from pgarbacki/initial_checkin

Upgrade to kafka 0.8.1.1