MINOR: Typo error corrected in the KStream Javadoc.
Author: Kamal C
Reviewers: Matthias J. Sax Damian Guy
Closes from Kamal15/stream_doc
@@ -122,7 +122,7 @@ public interface KStream<K, V> {
* The example below normalizes the String key to upper-case letters and counts the number of token of the value string.
* <pre>{@code
* KStream<String, String> inputStream = builder.stream("topic");
- * KStream<Integer, String> outputStream = inputStream.map(new KeyValueMapper<String, String, KeyValue<String, Integer>> {
+ * KStream<String, Integer> outputStream = inputStream.map(new KeyValueMapper<String, String, KeyValue<String, Integer>> {
* KeyValue<String, Integer> apply(String key, String value) {
* return new KeyValue<>(key.toUpperCase(), value.split(" ").length);
* }
@@ -1234,7 +1234,7 @@ public interface KStream<K, V> {
final Serde<VO> otherValueSerde);
/**
- * Join records of this stream with another {@code KStream}'s records using windowed left equi join with default
+ * Join records of this stream with another {@code KStream}'s records using windowed outer equi join with default
* serializers and deserializers.
* In contrast to {@link #join(KStream, ValueJoiner, JoinWindows) inner-join} or
* {@link #leftJoin(KStream, ValueJoiner, JoinWindows) left-join}, all records from both streams will produce at
@@ -1315,7 +1315,7 @@ public interface KStream<K, V> {
final JoinWindows windows);
/**
- * Join records of this stream with another {@code KStream}'s records using windowed left equi join.
+ * Join records of this stream with another {@code KStream}'s records using windowed outer equi join.
* In contrast to {@link #join(KStream, ValueJoiner, JoinWindows, Serde, Serde, Serde) inner-join} or
* {@link #leftJoin(KStream, ValueJoiner, JoinWindows, Serde, Serde, Serde) left-join}, all records from both
* streams will produce at least one output record (cf. below).
