This project demonstrates using a producer and consumer written in Java to interact with Kafka - View it on GitHub