mjsax commented on a change in pull request #8483:
URL: https://github.com/apache/kafka/pull/8483#discussion_r414732356
##########
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##########
@@ -855,6 +856,20 @@ public void advanceWallClockTime(final Duration advance) {
return new TestOutputTopic<>(this, topicName, keyDeserializer,
valueDeserializer);
}
+ /**
+ * Get all the names of all the topics to which records have been output.
+ * <p>
+ * Call this method after piping the input into the test driver to
retrieve the full set of topics the topology
+ * produced records to.
+ * <p>
+ * The returned set of topic names includes changelog, repartition and
sink topic names.
+ *
+ * @return the set of output topic names.
+ */
+ public final Set<String> getOutputTopicNames() {
Review comment:
@big-andy-coates Can you update the method name according to the KIP
discussion?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
