mirror of https://github.com/apache/kafka.git
MINOR: Fix menu ordering in streams docs
https://issues.apache.org/jira/browse/KAFKA-6419 Related: https://github.com/apache/kafka-site/pull/115 Author: Joel Hamill <joel-hamill@users.noreply.github.com> Reviewers: Guozhang Wang <wangguoz@gmail.com> Closes #4390 from joel-hamill/fix-streams-menu-order
This commit is contained in:
parent
e1c407973f
commit
26270983cd
|
@ -19,6 +19,19 @@
|
|||
|
||||
<script id="content-template" type="text/x-handlebars-template">
|
||||
<h1>Architecture</h1>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
Kafka Streams simplifies application development by building on the Kafka producer and consumer libraries and leveraging the native capabilities of
|
||||
Kafka to offer data parallelism, distributed coordination, fault tolerance, and operational simplicity. In this section, we describe how Kafka Streams works underneath the covers.
|
||||
|
@ -131,7 +144,7 @@
|
|||
|
||||
<div class="pagination">
|
||||
<a href="/{{version}}/documentation/streams/core-concepts" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide" class="pagination__btn pagination__btn__next">Next</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart" class="pagination__btn pagination__btn__next">Next</a>
|
||||
</div>
|
||||
</script>
|
||||
|
||||
|
|
|
@ -23,10 +23,12 @@
|
|||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
@ -167,7 +169,7 @@
|
|||
</p>
|
||||
|
||||
<div class="pagination">
|
||||
<a href="/{{version}}/documentation/streams/developer-guide" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture" class="pagination__btn pagination__btn__next">Next</a>
|
||||
</div>
|
||||
</script>
|
||||
|
|
|
@ -128,7 +128,7 @@
|
|||
</div>
|
||||
<div class="pagination">
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/security" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/" class="pagination__btn pagination__btn__next">Next</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide" class="pagination__btn pagination__btn__next">Next</a>
|
||||
</div>
|
||||
</script>
|
||||
|
||||
|
|
|
@ -40,7 +40,7 @@
|
|||
<li>By specifying explicit SerDes when calling the appropriate API methods, thus overriding the defaults.</li>
|
||||
</ul>
|
||||
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#configuring-serdes" id="id1">Configuring SerDes</a></li>
|
||||
<li><a class="reference internal" href="#overriding-default-serdes" id="id2">Overriding default SerDes</a></li>
|
||||
|
@ -139,7 +139,7 @@
|
|||
</tbody>
|
||||
</table>
|
||||
<div class="admonition tip">
|
||||
<p class="first admonition-title">Tip</p>
|
||||
<p><b>Tip</b></p>
|
||||
<p class="last"><a class="reference external" href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/utils/Bytes.java">Bytes</a> is a wrapper for Java’s <code class="docutils literal"><span class="pre">byte[]</span></code> (byte array) that supports proper equality and ordering semantics. You may want to consider using <code class="docutils literal"><span class="pre">Bytes</span></code> instead of <code class="docutils literal"><span class="pre">byte[]</span></code> in your applications.</p>
|
||||
</div>
|
||||
</div>
|
||||
|
|
|
@ -37,7 +37,7 @@
|
|||
<p>The Kafka Streams DSL (Domain Specific Language) is built on top of the Streams Processor API. It is the recommended for
|
||||
most users, especially beginners. Most data processing operations can be expressed in just a few lines of DSL code.</p>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#overview" id="id7">Overview</a></li>
|
||||
<li><a class="reference internal" href="#creating-source-streams-from-kafka" id="id8">Creating source streams from Kafka</a></li>
|
||||
|
@ -1542,7 +1542,7 @@
|
|||
join, are delivered to the same stream task during processing.
|
||||
<strong>It is the responsibility of the user to ensure data co-partitioning when joining</strong>.</p>
|
||||
<div class="admonition tip">
|
||||
<p class="first admonition-title">Tip</p>
|
||||
<p><b>Tip</b></p>
|
||||
<p class="last">If possible, consider using <a class="reference internal" href="../concepts.html#streams-concepts-globalktable"><span class="std std-ref">global tables</span></a> (<code class="docutils literal"><span class="pre">GlobalKTable</span></code>) for joining because they do not require data co-partitioning.</p>
|
||||
</div>
|
||||
<p>The requirements for data co-partitioning are:</p>
|
||||
|
@ -2989,7 +2989,7 @@ t=5 (blue), which lead to a merge of sessions and an extension of a session, res
|
|||
</pre></div>
|
||||
</div>
|
||||
<div class="admonition tip">
|
||||
<p class="first admonition-title">Tip</p>
|
||||
<p><b>Tip</b></p>
|
||||
<p class="last">Even though we do not demonstrate it in this example, a stream processor can access any available state stores by
|
||||
calling <code class="docutils literal"><span class="pre">ProcessorContext#getStateStore()</span></code>. Only such state stores are available that (1) have been named in the
|
||||
corresponding <code class="docutils literal"><span class="pre">KStream#process()</span></code> method call (note that this is a different method than <code class="docutils literal"><span class="pre">Processor#process()</span></code>),
|
||||
|
|
|
@ -19,17 +19,19 @@
|
|||
|
||||
<script id="content-template" type="text/x-handlebars-template">
|
||||
<h1>Developer Guide for Kafka Streams</h1>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/developer-guide">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
</div>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
|
||||
<div class="section" id="developer-guide">
|
||||
|
@ -57,7 +59,7 @@
|
|||
</div>
|
||||
|
||||
<div class="pagination">
|
||||
<a href="/{{version}}/documentation/streams/" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/write-streams" class="pagination__btn pagination__btn__next">Next</a>
|
||||
</div>
|
||||
</script>
|
||||
|
|
|
@ -35,7 +35,7 @@
|
|||
<span id="streams-developer-guide-interactive-queries"></span><h1>Interactive Queries<a class="headerlink" href="#interactive-queries" title="Permalink to this headline"></a></h1>
|
||||
<p>Interactive queries allow you to leverage the state of your application from outside your application. The Kafka Streams API enables your applications to be queryable.</p>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#querying-local-state-stores-for-an-app-instance" id="id3">Querying local state stores for an app instance</a><ul>
|
||||
<li><a class="reference internal" href="#querying-local-key-value-stores" id="id4">Querying local key-value stores</a></li>
|
||||
|
@ -373,7 +373,7 @@ interactive queries</span></p>
|
|||
The value of this configuration property will vary across the instances of your application.
|
||||
When this property is set, Kafka Streams will keep track of the RPC endpoint information for every instance of an application, its state stores, and assigned stream partitions through instances of <a class="reference external" href="../javadocs/org/apache/kafka/streams/state/StreamsMetadata.html">StreamsMetadata</a>.</p>
|
||||
<div class="admonition tip">
|
||||
<p class="first admonition-title">Tip</p>
|
||||
<p><b>Tip</b></p>
|
||||
<p class="last">Consider leveraging the exposed RPC endpoints of your application for further functionality, such as
|
||||
piggybacking additional inter-application communication that goes beyond interactive queries.</p>
|
||||
</div>
|
||||
|
|
|
@ -37,7 +37,7 @@
|
|||
before the records are written to state stores or forwarded downstream to other nodes.</p>
|
||||
<p>The record caches are implemented slightly different in the DSL and Processor API.</p>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#record-caches-in-the-dsl" id="id1">Record caches in the DSL</a></li>
|
||||
<li><a class="reference internal" href="#record-caches-in-the-processor-api" id="id2">Record caches in the Processor API</a></li>
|
||||
|
@ -185,7 +185,7 @@
|
|||
<code class="docutils literal"><span class="pre">rocksdb.config.setter</span></code> configuration.</li>
|
||||
</ul>
|
||||
<div class="admonition tip">
|
||||
<p class="first admonition-title">Tip</p>
|
||||
<p><b>Tip</b></p>
|
||||
<p><strong>Iterators should be closed explicitly to release resources:</strong> Store iterators (e.g., <code class="docutils literal"><span class="pre">KeyValueIterator</span></code> and <code class="docutils literal"><span class="pre">WindowStoreIterator</span></code>) must be closed explicitly upon completeness to release resources such as open file handlers and in-memory read buffers, or use try-with-resources statement (available since JDK7) for this Closeable class.</p>
|
||||
<p class="last">Otherwise, stream application’s memory usage keeps increasing when running until it hits an OOM.</p>
|
||||
</div>
|
||||
|
|
|
@ -38,7 +38,7 @@
|
|||
processors with their associated state stores to compose the processor topology that represents a customized processing
|
||||
logic.</p>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#overview" id="id1">Overview</a></li>
|
||||
<li><a class="reference internal" href="#defining-a-stream-processor" id="id2">Defining a Stream Processor</a></li>
|
||||
|
@ -57,7 +57,7 @@
|
|||
<p>The Processor API can be used to implement both <strong>stateless</strong> as well as <strong>stateful</strong> operations, where the latter is
|
||||
achieved through the use of <a class="reference internal" href="#streams-developer-guide-state-store"><span class="std std-ref">state stores</span></a>.</p>
|
||||
<div class="admonition tip">
|
||||
<p class="first admonition-title">Tip</p>
|
||||
<p><b>Tip</b></p>
|
||||
<p class="last"><strong>Combining the DSL and the Processor API:</strong>
|
||||
You can combine the convenience of the DSL with the power and flexibility of the Processor API as described in the
|
||||
section <a class="reference internal" href="dsl-api.html#streams-developer-guide-dsl-process"><span class="std std-ref">Applying processors and transformers (Processor API integration)</span></a>.</p>
|
||||
|
|
|
@ -35,7 +35,7 @@
|
|||
<span id="streams-developer-guide-execution"></span><h1>Running Streams Applications<a class="headerlink" href="#running-streams-applications" title="Permalink to this headline"></a></h1>
|
||||
<p>You can run Java applications that use the Kafka Streams library without any additional configuration or requirements.</p>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#starting-a-kafka-streams-application" id="id3">Starting a Kafka Streams application</a></li>
|
||||
<li><a class="reference internal" href="#elastic-scaling-of-your-application" id="id4">Elastic scaling of your application</a><ul>
|
||||
|
@ -53,7 +53,7 @@
|
|||
also provides the ability to receive notification of the various states of the application. The ability to monitor the runtime
|
||||
status is discussed in <a class="reference internal" href="../monitoring.html#streams-monitoring"><span class="std std-ref">the monitoring guide</span></a>.</p>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#starting-a-kafka-streams-application" id="id3">Starting a Kafka Streams application</a></li>
|
||||
<li><a class="reference internal" href="#elastic-scaling-of-your-application" id="id4">Elastic scaling of your application</a><ul>
|
||||
|
|
|
@ -34,7 +34,7 @@
|
|||
<div class="section" id="streams-security">
|
||||
<span id="streams-developer-guide-security"></span><h1>Streams Security<a class="headerlink" href="#streams-security" title="Permalink to this headline"></a></h1>
|
||||
<div class="contents local topic" id="table-of-contents">
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#required-acl-setting-for-secure-kafka-clusters" id="id1">Required ACL setting for secure Kafka clusters</a></li>
|
||||
<li><a class="reference internal" href="#security-example" id="id2">Security example</a></li>
|
||||
|
|
|
@ -33,7 +33,7 @@
|
|||
|
||||
<div class="section" id="writing-a-streams-application">
|
||||
<span id="streams-write-app"></span><h1>Writing a Streams Application<a class="headerlink" href="#writing-a-streams-application" title="Permalink to this headline"></a></h1>
|
||||
<p class="topic-title first">Table of Contents</p>
|
||||
<p class="topic-title first"><b>Table of Contents</b></p>
|
||||
<ul class="simple">
|
||||
<li><a class="reference internal" href="#libraries-and-maven-artifacts" id="id1">Libraries and Maven artifacts</a></li>
|
||||
<li><a class="reference internal" href="#using-kafka-streams-within-your-application-code" id="id2">Using Kafka Streams within your application code</a></li>
|
||||
|
@ -48,6 +48,56 @@
|
|||
<dt><a class="reference internal" href="processor-api.html#streams-developer-guide-processor-api"><span class="std std-ref">Processor API</span></a></dt>
|
||||
<dd>A low-level API that lets you add and connect processors as well as interact directly with state stores. The Processor API provides you with even more flexibility than the DSL but at the expense of requiring more manual work on the side of the application developer (e.g., more lines of code).</dd>
|
||||
</dl>
|
||||
<div class="section" id="libraries-and-maven-artifacts">
|
||||
<span id="streams-developer-guide-maven"></span><h2>Libraries and Maven artifacts</h2>
|
||||
<p>This section lists the Kafka Streams related libraries that are available for writing your Kafka Streams applications.</p>
|
||||
<p>You can define dependencies on the following libraries for your Kafka Streams applications.</p>
|
||||
<table border="1" class="non-scrolling-table docutils">
|
||||
<colgroup>
|
||||
<col width="14%" />
|
||||
<col width="19%" />
|
||||
<col width="12%" />
|
||||
<col width="55%" />
|
||||
</colgroup>
|
||||
<thead valign="bottom">
|
||||
<tr class="row-odd"><th class="head">Group ID</th>
|
||||
<th class="head">Artifact ID</th>
|
||||
<th class="head">Version</th>
|
||||
<th class="head">Description</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody valign="top">
|
||||
<tr class="row-even"><td><code class="docutils literal"><span class="pre">org.apache.kafka</span></code></td>
|
||||
<td><code>kafka-streams</code></td>
|
||||
<td><code class="docutils literal"><span class="pre">1.0.0</span></code></td>
|
||||
<td>(Required) Base library for Kafka Streams.</td>
|
||||
</tr>
|
||||
<tr class="row-odd"><td><code class="docutils literal"><span class="pre">org.apache.kafka</span></code></td>
|
||||
<td><code class="docutils literal"><span class="pre">kafka-clients</span></code></td>
|
||||
<td><code class="docutils literal"><span class="pre">1.0.0</span></code></td>
|
||||
<td>(Required) Kafka client library. Contains built-in serializers/deserializers.</td>
|
||||
</tr>
|
||||
</tbody>
|
||||
</table>
|
||||
<div class="admonition tip">
|
||||
<p><b>Tip</b></p>
|
||||
<p class="last">See the section <a class="reference internal" href="datatypes.html#streams-developer-guide-serdes"><span class="std std-ref">Data Types and Serialization</span></a> for more information about Serializers/Deserializers.</p>
|
||||
</div>
|
||||
<p>Example <code class="docutils literal"><span class="pre">pom.xml</span></code> snippet when using Maven:</p>
|
||||
<div class="highlight-xml"><div class="highlight"><pre><span></span><span class="nt"><dependency></span>
|
||||
<span class="nt"><groupId></span>org.apache.kafka<span class="nt"></groupId></span>
|
||||
<span class="nt"><artifactId></span>kafka-streams<span class="nt"></artifactId></span>
|
||||
<span class="nt"><version></span>1.0.0<span class="nt"></version></span>
|
||||
<span class="nt"></dependency></span>
|
||||
<span class="nt"><dependency></span>
|
||||
<span class="nt"><groupId></span>org.apache.kafka<span class="nt"></groupId></span>
|
||||
<span class="nt"><artifactId></span>kafka-clients<span class="nt"></artifactId></span>
|
||||
<span class="nt"><version></span>1.0.0<span class="nt"></version></span>
|
||||
<span class="nt"></dependency></span>
|
||||
|
||||
</pre></div>
|
||||
</div>
|
||||
</div>
|
||||
<div class="section" id="using-kafka-streams-within-your-application-code">
|
||||
<h2>Using Kafka Streams within your application code<a class="headerlink" href="#using-kafka-streams-within-your-application-code" title="Permalink to this headline"></a></h2>
|
||||
<p>You can call Kafka Streams from anywhere in your application code, but usually these calls are made within the <code class="docutils literal"><span class="pre">main()</span></code> method of
|
||||
|
|
|
@ -17,18 +17,20 @@
|
|||
</script>
|
||||
<script id="streams-template" type="text/x-handlebars-template">
|
||||
<h1>Kafka Streams</h1>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<h3 class="streams_intro">The easiest way to write mission-critical real-time applications and microservices</h3>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<h3 class="streams_intro">The easiest way to write mission-critical real-time applications and microservices</h3>
|
||||
<p class="streams__description">Kafka Streams is a client library for building applications and microservices, where the input and output data are stored in Kafka clusters. It combines the simplicity of writing and deploying standard Java and Scala applications on the client side with the benefits of Kafka's server-side cluster technology.</p>
|
||||
<div class="video__series__grid">
|
||||
<div class="yt__video__block">
|
||||
|
@ -287,8 +289,8 @@
|
|||
</div>
|
||||
|
||||
<div class="pagination">
|
||||
<a href="#" class="pagination__btn pagination__btn__prev pagination__btn--disabled">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart" class="pagination__btn pagination__btn__next">Next</a>
|
||||
<a href="/{{version}}/documentation" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts" class="pagination__btn pagination__btn__next">Next</a>
|
||||
</div>
|
||||
|
||||
</script>
|
||||
|
|
|
@ -19,17 +19,19 @@
|
|||
<script id="content-template" type="text/x-handlebars-template">
|
||||
|
||||
<h1>Run Streams Demo Application</h1>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<p>
|
||||
This tutorial assumes you are starting fresh and have no existing Kafka or ZooKeeper data. However, if you have already started Kafka and
|
||||
ZooKeeper, feel free to skip the first two steps.
|
||||
|
@ -339,7 +341,7 @@ Looking beyond the scope of this concrete example, what Kafka Streams is doing h
|
|||
<p>You can now stop the console consumer, the console producer, the Wordcount application, the Kafka broker and the ZooKeeper server in order via <b>Ctrl-C</b>.</p>
|
||||
|
||||
<div class="pagination">
|
||||
<a href="/{{version}}/documentation/streams" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial" class="pagination__btn pagination__btn__next">Next</a>
|
||||
</div>
|
||||
</script>
|
||||
|
|
|
@ -19,16 +19,18 @@
|
|||
<script id="content-template" type="text/x-handlebars-template">
|
||||
<h1>Tutorial: Write a Streams Application</h1>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
<p>
|
||||
In this guide we will start from scratch on setting up your own project to write a stream processing application using Kafka Streams.
|
||||
It is highly recommended to read the <a href="/{{version}}/documentation/streams/quickstart">quickstart</a> first on how to run a Streams application written in Kafka Streams if you have not done so.
|
||||
|
|
|
@ -19,6 +19,19 @@
|
|||
|
||||
<script id="content-template" type="text/x-handlebars-template">
|
||||
<h1>Upgrade Guide & API Changes</h1>
|
||||
<div class="sub-nav-sticky">
|
||||
<div class="sticky-top">
|
||||
<div style="height:35px">
|
||||
<a href="/{{version}}/documentation/streams/">Introduction</a>
|
||||
<a href="/{{version}}/documentation/streams/core-concepts">Concepts</a>
|
||||
<a href="/{{version}}/documentation/streams/architecture">Architecture</a>
|
||||
<a href="/{{version}}/documentation/streams/quickstart">Run Demo App</a>
|
||||
<a href="/{{version}}/documentation/streams/tutorial">Tutorial: Write App</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/">Developer Guide</a>
|
||||
<a class="active-menu-item" href="/{{version}}/documentation/streams/upgrade-guide">Upgrade</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<p>
|
||||
If you want to upgrade from 1.0.x to 1.1.0 you don't need to make any code changes as the public API is fully backward compatible.
|
||||
|
@ -393,7 +406,7 @@
|
|||
</ul>
|
||||
|
||||
<div class="pagination">
|
||||
<a href="/{{version}}/documentation/streams/architecture" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="/{{version}}/documentation/streams/developer-guide/app-reset-tool" class="pagination__btn pagination__btn__prev">Previous</a>
|
||||
<a href="#" class="pagination__btn pagination__btn__next pagination__btn--disabled">Next</a>
|
||||
</div>
|
||||
</script>
|
||||
|
|
Loading…
Reference in New Issue