You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2018/06/27 23:59:18 UTC
[kafka] branch trunk updated: MINOR: Update consumer javadoc for
position method (#5100)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new b2ed7d8 MINOR: Update consumer javadoc for position method (#5100)
b2ed7d8 is described below
commit b2ed7d80dea092e4258d04c191d42682a4db950f
Author: Manikumar Reddy O <ma...@gmail.com>
AuthorDate: Thu Jun 28 05:29:14 2018 +0530
MINOR: Update consumer javadoc for position method (#5100)
Reviewers: Ismael Juma <is...@juma.me.uk>, Jason Gustafson <ja...@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