vvcephei commented on a change in pull request #9554:
URL: https://github.com/apache/kafka/pull/9554#discussion_r517005864
##########
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:
Hmm, is this supposed to match the output topic in L103 below? That one
says "result-topic".
##########
File path: docs/streams/upgrade-guide.html
##########
@@ -135,14 +134,12 @@ <h3><a id="streams_api_changes_260"
href="#streams_api_changes_260">Streams API
tasks to their new owners in the background. Check out <a
href="https://cwiki.apache.org/confluence/x/0i4lBg";>KIP-441</a>
for full details, including several new configs for control over this
new feature.
</p>
-
<p>
New end-to-end latency metrics have been added. These task-level
metrics will be logged at the INFO level and report the min and max end-to-end
latency of a record at the beginning/source node(s)
and end/terminal node(s) of a task. See <a
href="https://cwiki.apache.org/confluence/x/gBkRCQ";>KIP-613</a> for more
information.
</p>
-
<p>
- As of 2.6.0 Kafka Streams deprecates <code>KStream.through()</code> in
favor of the new <code>KStream.repartition()</code> operator
+ As of 2.6.0 Kafka Streams deprecates <code>KStream.through()</code> if
favor of the new <code>KStream.repartition()</code> operator
Review comment:
Seems like this change is wrong.
```suggestion
As of 2.6.0 Kafka Streams deprecates <code>KStream.through()</code>
in favor of the new <code>KStream.repartition()</code> operator
```
----------------------------------------------------------------
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:
[email protected]
