Changes to support Kafka 0.8.1.1 release
Merge pull request #192 from amithkanand/kafka_811

Changes to support Kafka 0.8.1.1 release