chia7712 commented on code in PR #21196:
URL: https://github.com/apache/kafka/pull/21196#discussion_r2637079098
##########
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java:
##########
@@ -1306,7 +1306,7 @@ public long position(TopicPartition partition, final
Duration timeout) {
* Get the last committed offsets for the given partitions (whether the
commit happened by this process or
* another). The returned offsets will be used as the position for the
consumer in the event of a failure.
* <p>
- * If any of the partitions requested do not exist, an exception would be
thrown.
+ * If any of the partitions requested do not exist, the result map will
contain null as the value for that partition.
Review Comment:
Please also update the docs for the method `committed(Set<TopicPartition>,
Duration)`
--
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]
