kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: Fixed javadoc for committed return value
Date Wed, 05 Aug 2015 23:33:56 GMT
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ć <sslavic@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ć <sslavic@gmail.com>
Authored: Wed Aug 5 16:34:57 2015 -0700
Committer: Guozhang Wang <wangguoz@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.
      */


Mime
View raw message