Wrapper to the Java API for interacting with Kafka