chia7712 commented on code in PR #19393:
URL: https://github.com/apache/kafka/pull/19393#discussion_r2061407189
##########
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##########
@@ -1634,7 +1635,8 @@ public Map<TopicPartition, Long>
beginningOffsets(Collection<TopicPartition> par
* @param partitions the partitions to get the earliest offsets
* @param timeout The maximum amount of time to await retrieval of the
beginning offsets
*
- * @return The earliest available offsets for the given partitions
+ * @return The earliest available offsets for the given partitions. If the
offset for a specific partition cannot be
Review Comment:
the returned value is inconsistent between classic consumer and async
consumer. I have opened https://issues.apache.org/jira/browse/KAFKA-19205 to
trace it. this PR should be pending for the ticket
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
