Basic example of using Java to create a producer and consumer that work with Kafka on HDInsight. Also a demonstration of the streaming api. - View it on GitHub