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 2018/01/26 19:31:40 UTC
[kafka] branch trunk updated: MINOR: Changed javadoc on
KafkaConsumer#endOffsets (#3470)
This is an automated email from the ASF dual-hosted git repository.
guozhang 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 a9af5c7 MINOR: Changed javadoc on KafkaConsumer#endOffsets (#3470)
a9af5c7 is described below
commit a9af5c79638cb6ac4e729cdd995facc6153e45db
Author: ekenny <er...@gmail.com>
AuthorDate: Fri Jan 26 14:31:37 2018 -0500
MINOR: Changed javadoc on KafkaConsumer#endOffsets (#3470)
---
.../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
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 0bbbcf1..1d84f84 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
@@ -1643,8 +1643,10 @@ public class KafkaConsumer<K, V> implements Consumer<K, V> {
}
/**
- * Get the last offset for the given partitions. The last offset of a partition is the offset of the upcoming
- * message, i.e. the offset of the last available message + 1.
+ * Get the last offset for the given partitions. The last offset of a partition is the offset of the upcoming
+ * message, i.e. the offset of the last available message + 1. If messages have never been written
+ * to the the partition, the offset returned will be 0.
+ *
* <p>
* Notice that this method may block indefinitely if the partition does not exist.
* This method does not change the current consumer position of the partitions.
--
To stop receiving notification emails like this one, please contact
guozhang@apache.org.