kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: KAFKA-3339: Fix java docs for seekToEnd and seekToBeginning.
Date Mon, 07 Mar 2016 19:28:46 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 33f330754 -> 25bde48e6


KAFKA-3339: Fix java docs for seekToEnd and seekToBeginning.

Author: Ashish Singh <asingh@cloudera.com>

Reviewers: Gwen Shapira

Closes #1021 from SinghAsDev/KAFKA-3339


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/25bde48e
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/25bde48e
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/25bde48e

Branch: refs/heads/trunk
Commit: 25bde48e6a43b0a2c1c9430eb560b43e160ae3ea
Parents: 33f3307
Author: Ashish Singh <asingh@cloudera.com>
Authored: Mon Mar 7 11:28:41 2016 -0800
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Mon Mar 7 11:28:41 2016 -0800

----------------------------------------------------------------------
 .../java/org/apache/kafka/clients/consumer/KafkaConsumer.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/25bde48e/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 c88f607..d7c8e14 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
@@ -1059,7 +1059,8 @@ public class KafkaConsumer<K, V> implements Consumer<K, V>
{
 
     /**
      * Seek to the first offset for each of the given partitions. This function evaluates
lazily, seeking to the
-     * final offset in all partitions only when {@link #poll(long)} or {@link #position(TopicPartition)}
are called.
+     * first offset in all partitions only when {@link #poll(long)} or {@link #position(TopicPartition)}
are called.
+     * If no partition is provided, seek to the first offset for all of the currently assigned
partitions.
      */
     public void seekToBeginning(TopicPartition... partitions) {
         acquire();
@@ -1078,6 +1079,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V>
{
     /**
      * Seek to the last offset for each of the given partitions. This function evaluates
lazily, seeking to the
      * final offset in all partitions only when {@link #poll(long)} or {@link #position(TopicPartition)}
are called.
+     * If no partition is provided, seek to the final offset for all of the currently assigned
partitions.
      */
     public void seekToEnd(TopicPartition... partitions) {
         acquire();


Mime
View raw message