kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Add Streams landing page
Date Sat, 22 Jul 2017 02:16:19 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 6c6cf014f -> 300f48018


MINOR: Add Streams landing page

Content and assets for the updated Streams API landing page

Author: Derrick Or <derrickor@gmail.com>

Reviewers: Michael G. Noll <michael@confluent.io>, Guozhang Wang <wangguoz@gmail.com>

Closes #3540 from derrickdoo/streams-landing-page


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/300f4801
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/300f4801
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/300f4801

Branch: refs/heads/trunk
Commit: 300f48018cf7835e3de6a998d4e50895a2714a4e
Parents: 6c6cf01
Author: Derrick Or <derrickor@gmail.com>
Authored: Fri Jul 21 19:16:14 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri Jul 21 19:16:14 2017 -0700

----------------------------------------------------------------------
 docs/images/icons/architecture--white.png  | Bin 0 -> 812 bytes
 docs/images/icons/architecture.png         | Bin 0 -> 818 bytes
 docs/images/icons/documentation--white.png | Bin 0 -> 1758 bytes
 docs/images/icons/documentation.png        | Bin 0 -> 1642 bytes
 docs/images/icons/tutorials--white.png     | Bin 0 -> 1047 bytes
 docs/images/icons/tutorials.png            | Bin 0 -> 985 bytes
 docs/images/streams-welcome.png            | Bin 0 -> 80530 bytes
 docs/streams/architecture.html             |   4 +-
 docs/streams/core-concepts.html            |  26 ++-
 docs/streams/developer-guide.html          |   8 +-
 docs/streams/index.html                    | 238 +++++++++++++++++++-----
 docs/streams/quickstart.html               |   2 +-
 docs/streams/upgrade-guide.html            |   6 +-
 docs/toc.html                              |  16 +-
 14 files changed, 226 insertions(+), 74 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/icons/architecture--white.png
----------------------------------------------------------------------
diff --git a/docs/images/icons/architecture--white.png b/docs/images/icons/architecture--white.png
new file mode 100644
index 0000000..98b1b03
Binary files /dev/null and b/docs/images/icons/architecture--white.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/icons/architecture.png
----------------------------------------------------------------------
diff --git a/docs/images/icons/architecture.png b/docs/images/icons/architecture.png
new file mode 100644
index 0000000..6f9fd40
Binary files /dev/null and b/docs/images/icons/architecture.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/icons/documentation--white.png
----------------------------------------------------------------------
diff --git a/docs/images/icons/documentation--white.png b/docs/images/icons/documentation--white.png
new file mode 100644
index 0000000..1e8fd97
Binary files /dev/null and b/docs/images/icons/documentation--white.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/icons/documentation.png
----------------------------------------------------------------------
diff --git a/docs/images/icons/documentation.png b/docs/images/icons/documentation.png
new file mode 100644
index 0000000..8d9da19
Binary files /dev/null and b/docs/images/icons/documentation.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/icons/tutorials--white.png
----------------------------------------------------------------------
diff --git a/docs/images/icons/tutorials--white.png b/docs/images/icons/tutorials--white.png
new file mode 100644
index 0000000..97a0c04
Binary files /dev/null and b/docs/images/icons/tutorials--white.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/icons/tutorials.png
----------------------------------------------------------------------
diff --git a/docs/images/icons/tutorials.png b/docs/images/icons/tutorials.png
new file mode 100644
index 0000000..983da6c
Binary files /dev/null and b/docs/images/icons/tutorials.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/images/streams-welcome.png
----------------------------------------------------------------------
diff --git a/docs/images/streams-welcome.png b/docs/images/streams-welcome.png
new file mode 100644
index 0000000..63918c4
Binary files /dev/null and b/docs/images/streams-welcome.png differ

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/streams/architecture.html
----------------------------------------------------------------------
diff --git a/docs/streams/architecture.html b/docs/streams/architecture.html
index 70c5c79..0dbb1dc 100644
--- a/docs/streams/architecture.html
+++ b/docs/streams/architecture.html
@@ -131,7 +131,7 @@
 
     <div class="pagination">
         <a href="/{{version}}/documentation/streams/core-concepts" 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>
 
@@ -143,7 +143,7 @@
         <!--#include virtual="../../includes/_docs_banner.htm" -->
         <ul class="breadcrumbs">
             <li><a href="/documentation">Documentation</a></li>
-            <li><a href="/documentation/streams">Streams</a></li>
+            <li><a href="/documentation/streams">Kafka Streams API</a></li>
         </ul>
         <div class="p-content"></div>
     </div>

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/streams/core-concepts.html
----------------------------------------------------------------------
diff --git a/docs/streams/core-concepts.html b/docs/streams/core-concepts.html
index 8efc212..7349c3a 100644
--- a/docs/streams/core-concepts.html
+++ b/docs/streams/core-concepts.html
@@ -21,6 +21,28 @@
     <h1>Core Concepts</h1>
 
     <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.
+    </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.
+        Kafka Streams transparently handles the load balancing of multiple instances of the
same application by leveraging Kafka's parallelism model.
+    </p>
+    <p>
+        Some highlights of Kafka Streams:
+    </p>
+
+    <ul>
+        <li>Designed as a <b>simple and lightweight client library</b>,
which can be easily embedded in any Java application and integrated with any existing packaging,
deployment and operational tools that users have for their streaming applications.</li>
+        <li>Has <b>no external dependencies on systems other than Apache Kafka
itself</b> as the internal messaging layer; notably, it uses Kafka's partitioning model
to horizontally scale processing while maintaining strong ordering guarantees.</li>
+        <li>Supports <b>fault-tolerant local state</b>, which enables very
fast and efficient stateful operations like windowed joins and aggregations.</li>
+        <li>Supports <b>exactly-once</b> processing semantics to guarantee
that each record will be processed once and only once even when there is a failure on either
Streams clients or Kafka brokers in the middle of processing.</li>
+        <li>Employs <b>one-record-at-a-time processing</b> to achieve millisecond
processing latency, and supports <b>event-time based windowing operations</b>
with late arrival of records.</li>
+        <li>Offers necessary stream processing primitives, along with a <b>high-level
Streams DSL</b> and a <b>low-level Processor API</b>.</li>
+
+    </ul>
+
+    <p>
         We first summarize the key concepts of Kafka Streams.
     </p>
 
@@ -135,7 +157,7 @@
     </p>
 
     <div class="pagination">
-        <a href="/{{version}}/documentation/streams/quickstart" class="pagination__btn
pagination__btn__prev">Previous</a>
+        <a href="/{{version}}/documentation/streams/developer-guide" class="pagination__btn
pagination__btn__prev">Previous</a>
         <a href="/{{version}}/documentation/streams/architecture" class="pagination__btn
pagination__btn__next">Next</a>
     </div>
 </script>
@@ -148,7 +170,7 @@
         <!--#include virtual="../../includes/_docs_banner.htm" -->
         <ul class="breadcrumbs">
             <li><a href="/documentation">Documentation</a></li>
-            <li><a href="/documentation/streams">Streams</a></li>
+            <li><a href="/documentation/streams">Kafka Streams API</a></li>
         </ul>
         <div class="p-content"></div>
     </div>

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/streams/developer-guide.html
----------------------------------------------------------------------
diff --git a/docs/streams/developer-guide.html b/docs/streams/developer-guide.html
index 27ff81b..542003d 100644
--- a/docs/streams/developer-guide.html
+++ b/docs/streams/developer-guide.html
@@ -18,7 +18,7 @@
 <script><!--#include virtual="../js/templateData.js" --></script>
 
 <script id="content-template" type="text/x-handlebars-template">
-    <h1>Developer Guide</h1>
+    <h1>Developer Manual</h1>
 
     <p>
         There is a <a href="/{{version}}/documentation/#quickstart_kafkastreams">quickstart</a>
example that provides how to run a stream processing program coded in the Kafka Streams library.
@@ -1132,8 +1132,8 @@
     </p>
 
     <div class="pagination">
-        <a href="/{{version}}/documentation/streams/architecture" 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__prev">Previous</a>
+        <a href="/{{version}}/documentation/streams/core-concepts" class="pagination__btn
pagination__btn__next">Next</a>
     </div>
 </script>
 
@@ -1145,7 +1145,7 @@
         <!--#include virtual="../../includes/_docs_banner.htm" -->
         <ul class="breadcrumbs">
             <li><a href="/documentation">Documentation</a></li>
-            <li><a href="/documentation/streams">Streams</a></li>
+            <li><a href="/documentation/streams">Kafka Streams API</a></li>
         </ul>
         <div class="p-content"></div>
     </div>

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/streams/index.html
----------------------------------------------------------------------
diff --git a/docs/streams/index.html b/docs/streams/index.html
index 7a3c36b..bcaa831 100644
--- a/docs/streams/index.html
+++ b/docs/streams/index.html
@@ -18,56 +18,192 @@
 <script><!--#include virtual="../js/templateData.js" --></script>
 
 <script id="streams-template" type="text/x-handlebars-template">
-    <h1>Streams</h1>
-
-    <ol class="toc">
-        <li>
-            <a href="/{{version}}/documentation/streams/quickstart">Play with a Streams
Application</a>
-        </li>
-        <li>
-            <a href="/{{version}}/documentation/streams/core-concepts">Core Concepts</a>
-        </li>
-        <li>
-            <a href="/{{version}}/documentation/streams/architecture">Architecture</a>
-        </li>
-        <li>
-            <a href="/{{version}}/documentation/streams/developer-guide">Developer
Guide</a>
-            <ul>
-                <li><a href="/{{version}}/documentation/streams/developer-guide#streams_processor">Low-level
Processor API</a></li>
-                <li><a href="/{{version}}/documentation/streams/developer-guide#streams_dsl">High-level
Streams DSL</a></li>
-                <li><a href="/{{version}}/documentation/streams/developer-guide#streams_interactive_querie">Interactive
Queries</a></li>
-                <li><a href="/{{version}}/documentation/streams/developer-guide#streams_execute">Application
Configuration and Execution</a></li>
-            </ul>
-        </li>
-        <li>
-            <a href="/{{version}}/documentation/streams/upgrade-guide">Upgrade Guide
and API Changes</a>
-        </li>
-    </ol>
-
-    <h2>Overview</h2>
-
-    <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.
-    </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.
-        Kafka Streams transparently handles the load balancing of multiple instances of the
same application by leveraging Kafka's parallelism model.
-    </p>
-    <p>
-        Some highlights of Kafka Streams:
-    </p>
-
-    <ul>
-        <li>Designed as a <b>simple and lightweight client library</b>,
which can be easily embedded in any Java application and integrated with any existing packaging,
deployment and operational tools that users have for their streaming applications.</li>
-        <li>Has <b>no external dependencies on systems other than Apache Kafka
itself</b> as the internal messaging layer; notably, it uses Kafka's partitioning model
to horizontally scale processing while maintaining strong ordering guarantees.</li>
-        <li>Supports <b>fault-tolerant local state</b>, which enables very
fast and efficient stateful operations like windowed joins and aggregations.</li>
-        <li>Supports <b>exactly-once</b> processing semantics to guarantee
that each record will be processed once and only once even when there is a failure on either
Streams clients or Kafka brokers in the middle of processing.</li>
-        <li>Employs <b>one-record-at-a-time processing</b> to achieve millisecond
processing latency, and supports <b>event-time based windowing operations</b>
with late arrival of records.</li>
-        <li>Offers necessary stream processing primitives, along with a <b>high-level
Streams DSL</b> and a <b>low-level Processor API</b>.</li>
+    <h1>Kafka Streams API</h1>
 
+    <h3 style="max-width: 75rem;">The easiest way to write mission-critical real-time
applications and microservices with all the benefits of Kafka's server-side cluster technology.</h3>
+
+    <div class="hero">
+        <div class="hero__diagram">
+            <img src="/{{version}}/images/streams-welcome.png" />
+        </div>
+        <div class="hero__cta">
+            <a style="display: none;" href="/{{version}}/documentation/streams/tutorial"
class="btn">Write your first app</a>
+            <a href="/{{version}}/documentation/streams/quickstart" class="btn">Play
with demo app</a>
+        </div>
+    </div>
+
+    <ul class="feature-list">
+        <li>Write standard Java applications</li>
+        <li>Exactly-once processing semantics</li>
+        <li>No seperate processing cluster required</li>
+        <li>Develop on Mac, Linux, Windows</li>
+        <li>Elastic, highly scalable, fault-tolerant</li>
+        <li>Deploy to containers, VMs, bare metal, cloud</li>
+        <li>Equally viable for small, medium, &amp; large use cases</li>
+        <li>Fully integrated with Kafka security</li>
     </ul>
 
+    <div class="cards">
+        <a class="card" href="/{{version}}/documentation/streams/developer-guide">
+            <img class="card__icon" src="/{{version}}/images/icons/documentation.png"
/>
+            <img class="card__icon card__icon--hover" src="/{{version}}/images/icons/documentation--white.png"
/>
+            <span class="card__label">Developer manual</span>
+        </a>
+        <a style="display: none;" class="card" href="/{{version}}/documentation/streams/tutorial">
+            <img class="card__icon" src="/{{version}}/images/icons/tutorials.png" />
+            <img class="card__icon card__icon--hover" src="/{{version}}/images/icons/tutorials--white.png"
/>
+            <span class="card__label">Tutorials</span>
+        </a>
+        <a class="card" href="/{{version}}/documentation/streams/core-concepts">
+            <img class="card__icon" src="/{{version}}/images/icons/architecture.png" />
+            <img class="card__icon card__icon--hover" src="/{{version}}/images/icons/architecture--white.png"
/>
+            <span class="card__label">Concepts</span>
+        </a>
+    </div>
+
+    <h3>Hello Kafka Streams</h3>
+    <p>The code example below implements a WordCount application that is elastic, highly
scalable, fault-tolerant, stateful, and ready to run in production at large scale</p>
+
+    <div class="code-example">
+        <div class="btn-group">
+            <a class="selected b-java-8" data-section="java-8">Java 8+</a>
+            <a class="b-java-7" data-section="java-7">Java 7</a>
+            <a class="b-scala" data-section="scala">Scala</a>
+        </div>
+
+        <div class="code-example__snippet b-java-8 selected">
+            <pre class="brush: java;">
+                import org.apache.kafka.common.serialization.Serdes;
+                import org.apache.kafka.streams.KafkaStreams;
+                import org.apache.kafka.streams.StreamsConfig;
+                import org.apache.kafka.streams.kstream.KStream;
+                import org.apache.kafka.streams.kstream.KStreamBuilder;
+                import org.apache.kafka.streams.kstream.KTable;
+
+                import java.util.Arrays;
+                import java.util.Properties;
+
+                public class WordCountApplication {
+
+                    public static void main(final String[] args) throws Exception {
+                        Properties config = new Properties();
+                        config.put(StreamsConfig.APPLICATION_ID_CONFIG, "wordcount-application");
+                        config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-broker1:9092");
+                        config.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
+                        config.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
+
+                        KStreamBuilder builder = new KStreamBuilder();
+                        KStream&lt;String, String&gt; textLines = builder.stream("TextLinesTopic");
+                        KTable&lt;String, Long&gt; wordCounts = textLines
+                            .flatMapValues(textLine -> Arrays.asList(textLine.toLowerCase().split("\\W+")))
+                            .groupBy((key, word) -> word)
+                            .count("Counts");
+                        wordCounts.to(Serdes.String(), Serdes.Long(), "WordsWithCountsTopic");
+
+                        KafkaStreams streams = new KafkaStreams(builder, config);
+                        streams.start();
+                    }
+
+                }
+            </pre>
+        </div>
+
+        <div class="code-example__snippet b-java-7">
+            <pre class="brush: java;">
+                import org.apache.kafka.common.serialization.Serdes;
+                import org.apache.kafka.streams.KafkaStreams;
+                import org.apache.kafka.streams.StreamsConfig;
+                import org.apache.kafka.streams.kstream.KStream;
+                import org.apache.kafka.streams.kstream.KStreamBuilder;
+                import org.apache.kafka.streams.kstream.KTable;
+                import org.apache.kafka.streams.kstream.KeyValueMapper;
+                import org.apache.kafka.streams.kstream.ValueMapper;
+
+                import java.util.Arrays;
+                import java.util.Properties;
+
+                public class WordCountApplication {
+
+                    public static void main(final String[] args) throws Exception {
+                        Properties config = new Properties();
+                        config.put(StreamsConfig.APPLICATION_ID_CONFIG, "wordcount-application");
+                        config.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-broker1:9092");
+                        config.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
+                        config.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
+
+                        KStreamBuilder builder = new KStreamBuilder();
+                        KStream&lt;String, String&gt; textLines = builder.stream("TextLinesTopic");
+                        KTable&lt;String, Long&gt; wordCounts = textLines
+                            .flatMapValues(new ValueMapper&lt;String, Iterable&lt;String&gt;&gt;()
{
+                                @Override
+                                public Iterable&lt;String&gt; apply(String textLine)
{
+                                    return Arrays.asList(textLine.toLowerCase().split("\\W+"));
+                                }
+                            })
+                            .groupBy(new KeyValueMapper&lt;String, String, String&gt;()
{
+                                @Override
+                                public String apply(String key, String word) {
+                                    return word;
+                                }
+                            })
+                            .count("Counts");
+                        wordCounts.to(Serdes.String(), Serdes.Long(), "WordsWithCountsTopic");
+
+                        KafkaStreams streams = new KafkaStreams(builder, config);
+                        streams.start();
+                    }
+
+                }
+            </pre>
+        </div>
+
+        <div class="code-example__snippet b-scala">
+            <pre class="brush: scala;">
+                import java.lang.Long
+                import java.util.Properties
+                import java.util.concurrent.TimeUnit
+
+                import org.apache.kafka.common.serialization._
+                import org.apache.kafka.streams._
+                import org.apache.kafka.streams.kstream.{KStream, KStreamBuilder, KTable}
+
+                import scala.collection.JavaConverters.asJavaIterableConverter
+
+                object WordCountApplication {
+
+                    def main(args: Array[String]) {
+                        val config: Properties = {
+                            val p = new Properties()
+                            p.put(StreamsConfig.APPLICATION_ID_CONFIG, "wordcount-application")
+                            p.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka-broker1:9092")
+                            p.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass)
+                            p.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass)
+                            p
+                        }
+
+                        val builder: KStreamBuilder = new KStreamBuilder()
+                        val textLines: KStream[String, String] = builder.stream("TextLinesTopic")
+                        val wordCounts: KTable[String, Long] = textLines
+                            .flatMapValues(textLine => textLine.toLowerCase.split("\\W+").toIterable.asJava)
+                            .groupBy((_, word) => word)
+                            .count("Counts")
+                        wordCounts.to(Serdes.String(), Serdes.Long(), "WordsWithCountsTopic")
+
+                        val streams: KafkaStreams = new KafkaStreams(builder, config)
+                        streams.start()
+
+                        Runtime.getRuntime.addShutdownHook(new Thread(() => {
+                            streams.close(10, TimeUnit.SECONDS)
+                        }))
+                    }
+
+                }
+            </pre>
+        </div>
+    </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>
@@ -87,6 +223,7 @@
     </div>
 </div>
 <!--#include virtual="../../includes/_footer.htm" -->
+
 <script>
 $(function() {
   // Show selected style on nav item
@@ -94,5 +231,12 @@ $(function() {
 
   // Display docs subnav items
   $('.b-nav__docs').parent().toggleClass('nav__item__with__subs--expanded');
+
+  // Show selected code example
+  $('.btn-group a').click(function(){
+      var targetClass = '.b-' + $(this).data().section;
+      $('.code-example__snippet, .btn-group a').removeClass('selected');
+      $(targetClass).addClass('selected');
+  });
 });
 </script>

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/streams/quickstart.html
----------------------------------------------------------------------
diff --git a/docs/streams/quickstart.html b/docs/streams/quickstart.html
index a0e8273..1c45e16 100644
--- a/docs/streams/quickstart.html
+++ b/docs/streams/quickstart.html
@@ -227,7 +227,7 @@ console consumer, as described above).
 
  <div class="pagination">
         <a href="/{{version}}/documentation/streams" class="pagination__btn pagination__btn__prev">Previous</a>
-        <a href="/{{version}}/documentation/streams/core-concepts" class="pagination__btn
pagination__btn__next">Next</a>
+        <a href="/{{version}}/documentation/streams/developer-guide" class="pagination__btn
pagination__btn__next">Next</a>
     </div>
 </script>
 

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/streams/upgrade-guide.html
----------------------------------------------------------------------
diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html
index f2d9332..7f2c9f6 100644
--- a/docs/streams/upgrade-guide.html
+++ b/docs/streams/upgrade-guide.html
@@ -100,7 +100,7 @@
         <li> at-least-once (default): <code>[client.Id]-StreamThread-[sequence-number]</code>
</li>
         <li> exactly-once: <code>[client.Id]-StreamThread-[sequence-number]-[taskId]</code>
</li>
     </ul>
-    <p> <code>[client.Id]</code> is either set via Streams configuration
parameter <code>client.id<code> or defaults to <code>[application.id]-[processId]</code>
(<code>[processId]</code> is a random UUID). </p>
+    <p> <code>[client.Id]</code> is either set via Streams configuration
parameter <code>client.id</code> or defaults to <code>[application.id]-[processId]</code>
(<code>[processId]</code> is a random UUID). </p>
 
     <h3><a id="streams_api_changes_01021" href="#streams_api_changes_01021">Notable
changes in 0.10.2.1</a></h3>
 
@@ -218,7 +218,7 @@
     </ul>
 
     <div class="pagination">
-        <a href="/{{version}}/documentation/streams/developer-guide" class="pagination__btn
pagination__btn__prev">Previous</a>
+        <a href="/{{version}}/documentation/streams/architecture" class="pagination__btn
pagination__btn__prev">Previous</a>
         <a href="#" class="pagination__btn pagination__btn__next pagination__btn--disabled">Next</a>
     </div>
 </script>
@@ -231,7 +231,7 @@
         <!--#include virtual="../../includes/_docs_banner.htm" -->
         <ul class="breadcrumbs">
             <li><a href="/documentation">Documentation</a></li>
-            <li><a href="/documentation/streams">Streams</a></li>
+            <li><a href="/documentation/streams">Kafka Streams API</a></li>
         </ul>
         <div class="p-content"></div>
     </div>

http://git-wip-us.apache.org/repos/asf/kafka/blob/300f4801/docs/toc.html
----------------------------------------------------------------------
diff --git a/docs/toc.html b/docs/toc.html
index 2a53c29..7525b0f 100644
--- a/docs/toc.html
+++ b/docs/toc.html
@@ -33,7 +33,7 @@
             <ul>
                 <li><a href="#producerapi">2.1 Producer API</a>
                 <li><a href="#consumerapi">2.2 Consumer API</a>
-                <li><a href="#streamsapi">2.3 Streams API</a>
+                <li><a href="/{{version}}/documentation/streams">2.3 Streams
API</a>
                 <li><a href="#connectapi">2.4 Connect API</a>
                 <li><a href="#adminapi">2.5 AdminClient API</a>
                 <li><a href="#legacyapis">2.6 Legacy APIs</a>
@@ -141,20 +141,6 @@
                 <li><a href="#connect_development">8.3 Connector Development
Guide</a></li>
             </ul>
         </li>
-        <li><a href="/{{version}}/documentation/streams">9. Kafka Streams</a>
-            <ul>
-                <li><a href="/{{version}}/documentation/streams#streams_overview">9.1
Overview</a></li>
-                <li><a href="/{{version}}/documentation/streams#streams_concepts">9.2
Core Concepts</a></li>
-                <li><a href="/{{version}}/documentation/streams#streams_architecture">9.3
Architecture</a></li>
-                <li><a href="/{{version}}/documentation/streams#streams_developer">9.4
Developer Guide</a></li>
-                <ul>
-                    <li><a href="/{{version}}/documentation/streams#streams_processor">Low-Level
Processor API</a></li>
-                    <li><a href="/{{version}}/documentation/streams#streams_dsl">High-Level
Streams DSL</a></li>
-                    <li><a href="/{{version}}/documentation/streams#streams_execute">Application
Configuration and Execution</a></li>
-                </ul>
-                <li><a href="/{{version}}/documentation/streams#streams_upgrade_and_api">9.5
Upgrade Guide and API Changes</a></li>
-            </ul>
-        </li>
     </ul>
 
 </script>


Mime
View raw message