This is an automated email from the ASF dual-hosted git repository.
chia7712 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 12e135bd264 MINOR: Fix Javadoc code sample in KafkaShareConsumer
(#22974)
12e135bd264 is described below
commit 12e135bd26411448f80d0b566d7f42d31090a5ae
Author: Sanskar Jhajharia <[email protected]>
AuthorDate: Tue Jul 28 19:36:24 2026 +0530
MINOR: Fix Javadoc code sample in KafkaShareConsumer (#22974)
The class-level Javadoc example used `Optional.getOrElse(...)`, which
isn't a method on `java.util.Optional` (should be `orElse`), and
referenced an undefined `rec` variable instead of the actual loop
variable `record`.
Reviewers: Chia-Ping Tsai <[email protected]>
---
.../java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java
index 53c1038667f..669153d76a9 100644
---
a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java
+++
b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java
@@ -305,10 +305,10 @@ import static
org.apache.kafka.common.utils.Utils.propsToMap;
* ConsumerRecords<String, String> records =
consumer.poll(Duration.ofMillis(1000));
*
* // Get the acquisition lock timeout and prepare to wait half that
time before renewing again
- * int timeToWaitMs =
consumer.acquisitionLockTimeoutMs().getOrElse(10000) / 2;
+ * int timeToWaitMs =
consumer.acquisitionLockTimeoutMs().orElse(10000) / 2;
*
* for (ConsumerRecord<String, String> record : records) {
- * if (processing.put(rec.offset(), rec) == null) {
+ * if (processing.put(record.offset(), record) == null) {
* // Start the processing on another thread
* }
*
