This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a42c4ed MINOR: Fix typos in KStream javadoc (#4550)
a42c4ed is described below
commit a42c4edfa79dfe66424fbfc356d126a3a689a3c1
Author: Michael Arndt <ar...@menedev.de>
AuthorDate: Tue Feb 13 03:33:59 2018 +0100
MINOR: Fix typos in KStream javadoc (#4550)
Reviewers: Guozhang Wang <wangg...@gmail.com>
---
streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
index cd59fd5..6a68f0c 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java
@@ -1323,7 +1323,7 @@ public interface KStream<K, V> {
* and default serializers and deserializers.
* Grouping a stream on the record key is required before an aggregation
operator can be applied to the data
* (cf. {@link KGroupedStream}).
- * The {@link KeyValueMapper} selects a new key (with should be of the
same type) while preserving the original values.
+ * The {@link KeyValueMapper} selects a new key (which should be of the
same type) while preserving the original values.
* If the new record key is {@code null} the record will not be included
in the resulting {@link KGroupedStream}
* <p>
* Because a new key is selected, an internal repartitioning topic will be
created in Kafka.
@@ -1349,7 +1349,7 @@ public interface KStream<K, V> {
* and {@link Serde}s as specified by {@link Serialized}.
* Grouping a stream on the record key is required before an aggregation
operator can be applied to the data
* (cf. {@link KGroupedStream}).
- * The {@link KeyValueMapper} selects a new key (with should be of the
same type) while preserving the original values.
+ * The {@link KeyValueMapper} selects a new key (which should be of the
same type) while preserving the original values.
* If the new record key is {@code null} the record will not be included
in the resulting {@link KGroupedStream}.
* <p>
* Because a new key is selected, an internal repartitioning topic will be
created in Kafka.
--
To stop receiving notification emails like this one, please contact
guozh...@apache.org.
