kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch 2.0 updated: MINOR: Update consumer javadoc for position method (#5100)
Date Thu, 28 Jun 2018 00:02:14 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.0 by this push:
     new 95e39f7  MINOR: Update consumer javadoc for position method (#5100)
95e39f7 is described below

commit 95e39f746486d6b6b1fcf1decdfd0d2a985b2f3a
Author: Manikumar Reddy O <manikumar.reddy@gmail.com>
AuthorDate: Thu Jun 28 05:29:14 2018 +0530

    MINOR: Update consumer javadoc for position method (#5100)
    
    Reviewers: Ismael Juma <ismael@juma.me.uk>, Jason Gustafson <jason@confluent.io>
---
 .../src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 971b0e7..550bece 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
@@ -1600,7 +1600,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V>
{
      * @param partition The partition to get the position for
      * @param timeout The maximum amount of time to await determination of the current position
      * @return The current position of the consumer (that is, the offset of the next record
to be fetched)
-     * @throws IllegalArgumentException if the provided TopicPartition is not assigned to
this consumer
+     * @throws IllegalStateException if the provided TopicPartition is not assigned to this
consumer
      * @throws org.apache.kafka.clients.consumer.InvalidOffsetException if no offset is currently
defined for
      *             the partition
      * @throws org.apache.kafka.common.errors.WakeupException if {@link #wakeup()} is called
before or while this


Mime
View raw message