Wrapper to the Java API for interacting with Kafka - View it on GitHub