kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: fixed some JavaDoc typos
Date Tue, 07 Feb 2017 07:09:02 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 588c5667f -> 7bb1d2a44


MINOR: fixed some JavaDoc typos

Author: Matthias J. Sax <matthias@confluent.io>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #2497 from mjsax/hofixJavaDocs0102


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/7bb1d2a4
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/7bb1d2a4
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/7bb1d2a4

Branch: refs/heads/0.10.2
Commit: 7bb1d2a44cab8209557e6427c61f05a00140b73e
Parents: 588c566
Author: Matthias J. Sax <matthias@confluent.io>
Authored: Mon Feb 6 23:08:12 2017 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Mon Feb 6 23:08:12 2017 -0800

----------------------------------------------------------------------
 .../kafka/streams/kstream/KStreamBuilder.java     | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/7bb1d2a4/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java
----------------------------------------------------------------------
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java b/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java
index 2832689..0a3304d 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java
@@ -56,7 +56,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * The default {@code "auto.offset.reset"} strategy and default key and value deserializers
as specified in the
      * {@link StreamsConfig config} are used.
      * <p>
-     * If multiple topics are specified there are no ordering guaranteed for records from
different topics.
+     * If multiple topics are specified there is no ordering guarantee for records from different
topics.
      * <p>
      * Note that the specified input topics must be partitioned by key.
      * If this is not the case it is the user's responsibility to repartition the date before
any key based operation
@@ -73,7 +73,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * Create a {@link KStream} from the specified topics.
      * The default key and value deserializers as specified in the {@link StreamsConfig config}
are used.
      * <p>
-     * If multiple topics are specified there are no ordering guaranteed for records from
different topics.
+     * If multiple topics are specified there is no ordering guarantee for records from different
topics.
      * <p>
      * Note that the specified input topics must be partitioned by key.
      * If this is not the case it is the user's responsibility to repartition the date before
any key based operation
@@ -132,7 +132,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * Create a {@link KStream} from the specified topics.
      * The default {@code "auto.offset.reset"} strategy as specified in the {@link StreamsConfig
config} is used.
      * <p>
-     * If multiple topics are specified there are no ordering guaranteed for records from
different topics.
+     * If multiple topics are specified there is no ordering guarantee for records from different
topics.
      * <p>
      * Note that the specified input topics must be partitioned by key.
      * If this is not the case it is the user's responsibility to repartition the date before
any key based operation
@@ -153,7 +153,7 @@ public class KStreamBuilder extends TopologyBuilder {
     /**
      * Create a {@link KStream} from the specified topics.
      * <p>
-     * If multiple topics are specified there are no ordering guaranteed for records from
different topics.
+     * If multiple topics are specified there is no ordering guarantee for records from different
topics.
      * <p>
      * Note that the specified input topics must be partitioned by key.
      * If this is not the case it is the user's responsibility to repartition the date before
any key based operation
@@ -240,7 +240,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * {@link StreamsConfig config} are used.
      * Input {@link KeyValue records} with {@code null} key will be dropped.
      * <p>
-     * Note that the specified input topics must be partitioned by key.
+     * Note that the specified input topic must be partitioned by key.
      * If this is not the case the returned {@link KTable} will be corrupted.
      * <p>
      * The resulting {@link KTable} will be materialized in a local {@link KeyValueStore}
with the given
@@ -273,7 +273,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * The default key and value deserializers as specified in the {@link StreamsConfig config}
are used.
      * Input {@link KeyValue records} with {@code null} key will be dropped.
      * <p>
-     * Note that the specified input topics must be partitioned by key.
+     * Note that the specified input topic must be partitioned by key.
      * If this is not the case the returned {@link KTable} will be corrupted.
      * <p>
      * The resulting {@link KTable} will be materialized in a local {@link KeyValueStore}
with the given
@@ -309,7 +309,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * The default {@code "auto.offset.reset"} strategy as specified in the {@link StreamsConfig
config} is used.
      * Input {@link KeyValue records} with {@code null} key will be dropped.
      * <p>
-     * Note that the specified input topics must be partitioned by key.
+     * Note that the specified input topic must be partitioned by key.
      * If this is not the case the returned {@link KTable} will be corrupted.
      * <p>
      * The resulting {@link KTable} will be materialized in a local {@link KeyValueStore}
with the given
@@ -347,7 +347,7 @@ public class KStreamBuilder extends TopologyBuilder {
      * Create a {@link KTable} for the specified topic.
      * Input {@link KeyValue records} with {@code null} key will be dropped.
      * <p>
-     * Note that the specified input topics must be partitioned by key.
+     * Note that the specified input topic must be partitioned by key.
      * If this is not the case the returned {@link KTable} will be corrupted.
      * <p>
      * The resulting {@link KTable} will be materialized in a local {@link KeyValueStore}
with the given
@@ -492,7 +492,7 @@ public class KStreamBuilder extends TopologyBuilder {
     /**
      * Create a new instance of {@link KStream} by merging the given {@link KStream}s.
      * <p>
-     * There are nor ordering guaranteed for records from different {@link KStream}s.
+     * There is no ordering guarantee for records from different {@link KStream}s.
      *
      * @param streams the {@link KStream}s to be merged
      * @return a {@link KStream} containing all records of the given streams


Mime
View raw message