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/08/06 01:33:56 UTC
kafka git commit: MINOR: Fixed javadoc for committed return value
Repository: kafka
Updated Branches:
refs/heads/trunk 4b798f0de -> 907ee7b5e
MINOR: Fixed javadoc for committed return value
If no offset has been committed, then committed method does not return (null) value, instead NoOffsetForPartitionException is thrown in that case.
Author: Stevo Slavić <ss...@gmail.com>
Reviewers: Ismael, Guozhang
Closes #89 from sslavic/patch-4 and squashes the following commits:
5c0a152 [Stevo Slavić] MINOR: Fixed javadoc for committed return value
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/907ee7b5
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/907ee7b5
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/907ee7b5
Branch: refs/heads/trunk
Commit: 907ee7b5eae9e163e7abb24f97dedbaa78bc9d8c
Parents: 4b798f0
Author: Stevo Slavić <ss...@gmail.com>
Authored: Wed Aug 5 16:34:57 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Aug 5 16:34:57 2015 -0700
----------------------------------------------------------------------
.../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/907ee7b5/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 7851644..c57bba0 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
@@ -960,7 +960,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V> {
* consumer hasn't yet initialized it's cache of committed offsets.
*
* @param partition The partition to check
- * @return The last committed offset or null if no offset has been committed
+ * @return The last committed offset
* @throws NoOffsetForPartitionException If no offset has ever been committed by any process for the given
* partition.
*/