Updated KafkaConsumer