bbejeck commented on a change in pull request #9554: URL: https://github.com/apache/kafka/pull/9554#discussion_r517339026
########## File path: docs/streams/developer-guide/testing.html ########## @@ -73,67 +71,55 @@ <h2><a class="toc-backref" href="#testing-topologytestdriver" title="Permalink t You can use the test driver to verify that your specified processor topology computes the correct result with the manually piped in data records. The test driver captures the results records and allows to query its embedded state stores. - <pre> -// Processor API + <pre class="line-numbers"><code class="language-text">// Processor API Topology topology = new Topology(); topology.addSource("sourceProcessor", "input-topic"); topology.addProcessor("processor", ..., "sourceProcessor"); -topology.addSink("sinkProcessor", "result-topic", "processor"); +topology.addSink("sinkProcessor", "output-topic", "processor"); // or // using DSL StreamsBuilder builder = new StreamsBuilder(); -builder.stream("input-topic").filter(...).to("result-topic"); +builder.stream("input-topic").filter(...).to("output-topic"); Review comment: good catch! Thanks ---------------------------------------------------------------- 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