Improved KafkaConsumer for testing/prototyping.