Simple example for reading and writing into Kafka - View it on GitHub