Repository: kafka Updated Branches: refs/heads/0.9.0 0cd6e9464 -> 94dc1f939
MINOR: Fixed new consumer Javadoc typo Changed "an" to "and" Author: Alex Sherwin <[email protected]> Reviewers: Guozhang Wang Closes #601 from alex-sherwin/patch-1 (cherry picked from commit ea971397c8c1b8deedc48c4165aded42118eee43) Signed-off-by: Guozhang Wang <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/94dc1f93 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/94dc1f93 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/94dc1f93 Branch: refs/heads/0.9.0 Commit: 94dc1f939af05216b765c1c7592946568dc4d7ea Parents: 0cd6e94 Author: Alex Sherwin <[email protected]> Authored: Mon Nov 30 11:10:01 2015 -0800 Committer: Guozhang Wang <[email protected]> Committed: Mon Nov 30 11:10:09 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/94dc1f93/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 6237e08..1ad2368 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
