You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/11/30 20:10:06 UTC
kafka git commit: MINOR: Fixed new consumer Javadoc typo
Repository: kafka
Updated Branches:
refs/heads/trunk 78e7f87db -> ea971397c
MINOR: Fixed new consumer Javadoc typo
Changed "an" to "and"
Author: Alex Sherwin <al...@users.noreply.github.com>
Reviewers: Guozhang Wang
Closes #601 from alex-sherwin/patch-1
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ea971397
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ea971397
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ea971397
Branch: refs/heads/trunk
Commit: ea971397c8c1b8deedc48c4165aded42118eee43
Parents: 78e7f87
Author: Alex Sherwin <al...@github.com>
Authored: Mon Nov 30 11:10:01 2015 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Mon Nov 30 11:10:01 2015 -0800
----------------------------------------------------------------------
.../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/ea971397/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 233d7a2..6c15df3 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
@@ -290,7 +290,7 @@ import java.util.regex.Pattern;
* and {@link #subscribe(Pattern, ConsumerRebalanceListener)}.
* For example, when partitions are taken from a consumer the consumer will want to commit its offset for those partitions by
* implementing {@link ConsumerRebalanceListener#onPartitionsRevoked(Collection)}. When partitions are assigned to a
- * consumer, the consumer will want to look up the offset for those new partitions an correctly initialize the consumer
+ * consumer, the consumer will want to look up the offset for those new partitions and correctly initialize the consumer
* to that position by implementing {@link ConsumerRebalanceListener#onPartitionsAssigned(Collection)}.
* <p>
* Another common use for {@link ConsumerRebalanceListener} is to flush any caches the application maintains for