public final <K, V> TestOutputTopic<K, V> createOutputTopic(final String topicName,
                                                                final Deserializer<K> keyDeserializer,
                                                                final Deserializer<V> valueDeserializer) {
        return new TestOutputTopic<>(this, topicName, keyDeserializer, valueDeserializer);
    }
Create {@link TestOutputTopic} to be used for reading records from topic

@param topicName             the name of the topic
@param keyDeserializer   the Deserializer for the key type
@param valueDeserializer the Deserializer for the value type
@param <K> the key type
@param <V> the value type
@return {@link TestOutputTopic} object
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java