From 268cff704994693e177c38cd2a16bf5179765f33 Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Thu, 1 Sep 2016 12:21:55 -0700 Subject: [PATCH] KAFKA-4112: Remove alpha quality label from Kafka Streams in docs Rephrase 'alpha quality' wording in Streams section of api.html. Couple of other minor fixes in streams.html Author: Damian Guy Reviewers: Guozhang Wang, Ismael Juma, Michael G. Noll Closes #1811 from dguy/kstreams-312 --- docs/api.html | 15 ++++++++------- docs/streams.html | 4 ++-- 2 files changed, 10 insertions(+), 9 deletions(-) diff --git a/docs/api.html b/docs/api.html index c4572411c47..2cb9d864104 100644 --- a/docs/api.html +++ b/docs/api.html @@ -168,19 +168,20 @@ Examples showing how to use the consumer are given in the

2.3 Streams API

-As of the 0.10.0 release we have added a new client library named Kafka Streams to let users implement their stream processing -applications with data stored in Kafka topics. Kafka Streams is considered alpha quality and its public APIs are likely to change in -future releases. -You can use Kafka Streams by adding a dependency on the streams jar using -the following example maven co-ordinates (you can change the version numbers with new releases): +As of the 0.10.0 release we have added a stream processing engine to Apache Kafka called Kafka Streams, which is a client library that lets users implement their own stream processing applications for data stored in Kafka topics. +You can use Kafka Streams from within your Java applications by adding a dependency on the kafka-streams jar using the following maven co-ordinates: 
 	<dependency>
 	    <groupId>org.apache.kafka</groupId>
 	    <artifactId>kafka-streams</artifactId>
-	    <version>0.10.0.0</version>
+	    <version>0.10.0.1</version>
 	</dependency>
Examples showing how to use this library are given in the -javadocs (note those classes annotated with @InterfaceStability.Unstable, indicating their public APIs may change without backward-compatibility in future releases). \ No newline at end of file +javadocs and kafka streams overview. +

+ Please note that Kafka Streams is a new component of Kafka, and its public APIs may change in future releases. + We use the @InterfaceStability.Unstable annotation to denote classes whose APIs may change without backward-compatibility in future releases. +

\ No newline at end of file diff --git a/docs/streams.html b/docs/streams.html index cd2cd935a12..9c21ec4d7a6 100644 --- a/docs/streams.html +++ b/docs/streams.html @@ -260,7 +260,7 @@ from a single topic). KStreamBuilder builder = new KStreamBuilder(); KStream source1 = builder.stream("topic1", "topic2"); - KTable source2 = builder.table("topic3"); + KTable source2 = builder.table("topic3", "stateStoreName");
Transform a stream
@@ -298,7 +298,7 @@ based on them. 
     // written in Java 8+, using lambda expressions
-    KTable, Long> counts = source1.groupBykey().aggregate(
+    KTable, Long> counts = source1.groupByKey().aggregate(
         () -> 0L,  // initial value
         (aggKey, value, aggregate) -> aggregate + 1L,   // aggregating value
         TimeWindows.of("counts", 5000L).advanceBy(1000L), // intervals in milliseconds