kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix typos in KStream javadoc (#4550)
Date Tue, 13 Feb 2018 02:34:03 GMT
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 <arndt@menedev.de>
AuthorDate: Tue Feb 13 03:33:59 2018 +0100

    MINOR: Fix typos in KStream javadoc (#4550)
    
    Reviewers: Guozhang Wang <wangguoz@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
guozhang@apache.org.

Mime
View raw message