Java-based example of reading and writing to Apache Kafka from Apache Storm on HDInsight - View it on GitHub