mirror of https://github.com/apache/kafka.git
MINOR: Fix doc typos and grammar
This is contributed by mihbor on various doc fixes including: https://github.com/apache/kafka/pull/3224 https://github.com/apache/kafka/pull/3226 https://github.com/apache/kafka/pull/3229 Author: Guozhang Wang <wangguoz@gmail.com> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #3746 from guozhangwang/KMinor-doc-typos
This commit is contained in:
parent
b6adb2dc89
commit
5648dcc3e5
|
|
@ -22,7 +22,7 @@
|
|||
|
||||
<p>
|
||||
Kafka Streams is a client library for processing and analyzing data stored in Kafka.
|
||||
It builds upon important stream processing concepts such as properly distinguishing between event time and processing time, windowing support, and simple yet efficient management of application state.
|
||||
It builds upon important stream processing concepts such as properly distinguishing between event time and processing time, windowing support, and simple yet efficient management and real-time querying of application state.
|
||||
</p>
|
||||
<p>
|
||||
Kafka Streams has a <b>low barrier to entry</b>: You can quickly write and run a small-scale proof-of-concept on a single machine; and you only need to run additional instances of your application on multiple machines to scale up to high-volume production workloads.
|
||||
|
|
@ -57,7 +57,7 @@
|
|||
There are two special processors in the topology:
|
||||
|
||||
<ul>
|
||||
<li><b>Source Processor</b>: A source processor is a special type of stream processor that does not have any upstream processors. It produces an input stream to its topology from one or multiple Kafka topics by consuming records from these topics and forward them to its down-stream processors.</li>
|
||||
<li><b>Source Processor</b>: A source processor is a special type of stream processor that does not have any upstream processors. It produces an input stream to its topology from one or multiple Kafka topics by consuming records from these topics and forwarding them to its down-stream processors.</li>
|
||||
<li><b>Sink Processor</b>: A sink processor is a special type of stream processor that does not have down-stream processors. It sends any received records from its up-stream processors to a specified Kafka topic.</li>
|
||||
</ul>
|
||||
|
||||
|
|
|
|||
|
|
@ -448,7 +448,7 @@ Note that in the <code>WordCountProcessor</code> implementation, users need to r
|
|||
("alice", 1) --> ("alice", 3)
|
||||
</pre>
|
||||
|
||||
If these records a KStream and the stream processing application were to sum the values it would return <code>4</code>. If these records were a KTable or GlobalKTable, the return would be <code>3</code>, since the last record would be considered as an update.
|
||||
If the stream is defined as a KStream and the stream processing application were to sum the values it would return <code>4</code>. If the stream is defined as a KTable or GlobalKTable, the return would be <code>3</code>, since the last record would be considered as an update.
|
||||
|
||||
<h4><a id="streams_dsl_source" href="#streams_dsl_source">Creating Source Streams from Kafka</a></h4>
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue