A node.js stream for reading from a Kafka queue