Improved KafkaConsumer, faster, with ability to pass a consumer id to embedded kafka