Repository: kafka Updated Branches: refs/heads/trunk 01d58ad8e -> 36528df08
MINOR: Fix typos in KafkaConsumer docs Author: Jeff Widman <[email protected]> Reviewers: Jason Gustafson <[email protected]> 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 <[email protected]> Authored: Fri Dec 9 09:46:55 2016 -0800 Committer: Jason Gustafson <[email protected]> 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
