Added consume() and consumeOne() to writerTopic.