public final long getQueueSize() {
        return driver.getQueueSize(topic);
    }
Get size of unread record in the topic queue.

@return size of topic queue.
streams/test-utils/src/main/java/org/apache/kafka/streams/TestOutputTopic.java