Sample programs for the Kafka 0.9 API - View it on GitHub