kafka_impl

A wrapper around KafkaEx so you can mock it in test.