MINOR: Changed javadoc on KafkaConsumer#endOffsets (apache#3470)

wkh888888 · Jan 26, 2018 · a9af5c7 · a9af5c7
1 parent 739256b
commit a9af5c7
Showing 1 changed file with 4 additions and 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
@@ -1643,8 +1643,10 @@ public Map<TopicPartition, Long> beginningOffsets(Collection<TopicPartition> par
     }
 
     /**
-     * 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.