kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: MINOR: Fix typos in KafkaConsumer docs
Date Fri, 09 Dec 2016 17:47:35 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 01d58ad8e -> 36528df08


MINOR: Fix typos in KafkaConsumer docs

Author: Jeff Widman <jeff@jeffwidman.com>

Reviewers: Jason Gustafson <jason@confluent.io>

Closes #2178 from jeffwidman/patch-1


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

Branch: refs/heads/trunk
Commit: 36528df088a28b4373f148627627d7c116297209
Parents: 01d58ad
Author: Jeff Widman <jeff@jeffwidman.com>
Authored: Fri Dec 9 09:46:55 2016 -0800
Committer: Jason Gustafson <jason@confluent.io>
Committed: Fri Dec 9 09:46:55 2016 -0800

----------------------------------------------------------------------
 .../org/apache/kafka/clients/consumer/KafkaConsumer.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/36528df0/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index 93aa739..f89460b 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -832,9 +832,9 @@ public class KafkaConsumer<K, V> implements Consumer<K, V>
{
      *
      * <p>
      * This is a short-hand for {@link #subscribe(Collection, ConsumerRebalanceListener)},
which
-     * uses a noop listener. If you need the ability to either seek to particular offsets,
you should prefer
+     * uses a noop listener. If you need the ability to seek to particular offsets, you should
prefer
      * {@link #subscribe(Collection, ConsumerRebalanceListener)}, since group rebalances
will cause partition offsets
-     * to be reset. You should also prefer to provide your own listener if you are doing
your own offset
+     * to be reset. You should also provide your own listener if you are doing your own offset
      * management since the listener gives you an opportunity to commit offsets before a
rebalance finishes.
      *
      * @param topics The list of topics to subscribe to
@@ -898,10 +898,10 @@ public class KafkaConsumer<K, V> implements Consumer<K, V>
{
     }
 
     /**
-     * Manually assign a list of partition to this consumer. This interface does not allow
for incremental assignment
+     * Manually assign a list of partitions to this consumer. This interface does not allow
for incremental assignment
      * and will replace the previous assignment (if there is one).
      *
-     * If the given list of topic partition is empty, it is treated the same as {@link #unsubscribe()}.
+     * If the given list of topic partitions is empty, it is treated the same as {@link #unsubscribe()}.
      *
      * <p>
      * Manual topic assignment through this method does not use the consumer's group management


Mime
View raw message