Updated Kafka client