Checking in the first working version for Kafka-0.8