diff --git a/docs/api.html b/docs/api.html index 8d5be9b030d..c4572411c47 100644 --- a/docs/api.html +++ b/docs/api.html @@ -165,3 +165,22 @@ This new unified consumer API removes the distinction between the 0.8 high-level Examples showing how to use the consumer are given in the javadocs. + +

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): + +
+	<dependency>
+	    <groupId>org.apache.kafka</groupId>
+	    <artifactId>kafka-streams</artifactId>
+	    <version>0.10.0.0</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 diff --git a/docs/documentation.html b/docs/documentation.html index 70002ab8ec4..ddc31021801 100644 --- a/docs/documentation.html +++ b/docs/documentation.html @@ -40,6 +40,7 @@ Prior releases: 0.7.x, 2.2.2 Old Simple Consumer API
  • 2.2.3 New Consumer API +
  • 2.3 Streams API
  • 3. Configuration diff --git a/docs/quickstart.html b/docs/quickstart.html index 7a923c69fc0..4d4f7eae683 100644 --- a/docs/quickstart.html +++ b/docs/quickstart.html @@ -258,15 +258,15 @@ This quickstart example will demonstrate how to run a streaming application code of the WordCountDemo example code (converted to use Java 8 lambda expressions for easy reading). 

    -KStream wordCounts = textLines
-// Split each text line, by whitespace, into words.
-.flatMapValues(value -> Arrays.asList(value.toLowerCase().split("\\W+")))
-// Ensure the words are available as message keys for the next aggregate operation.
-.map((key, value) -> new KeyValue<>(value, value))
-// Count the occurrences of each word (message key).
-.countByKey(stringSerializer, longSerializer, stringDeserializer, longDeserializer, "Counts")
-// Convert the resulted aggregate table into another stream.
-.toStream();
+KTable wordCounts = textLines
+    // Split each text line, by whitespace, into words.
+    .flatMapValues(value -> Arrays.asList(value.toLowerCase().split("\\W+")))
+
+    // Ensure the words are available as record keys for the next aggregate operation.
+    .map((key, value) -> new KeyValue<>(value, value))
+
+    // Count the occurrences of each word (record key) and store the results into a table named "Counts".
+    .countByKey("Counts")

    diff --git a/docs/upgrade.html b/docs/upgrade.html index 486954c1c62..4b8ec7eb9f0 100644 --- a/docs/upgrade.html +++ b/docs/upgrade.html @@ -90,6 +90,7 @@ work with 0.10.0.x brokers. Therefore, 0.9.0.0 clients should be upgraded to 0.9

    Notable changes in 0.10.0.0