Sample Java Project that uses Kafka API - View it on GitHub