commit c49ab6b4ae69e3c4ad0ea31acb99223f19897ce7
author Now <156046839+Kguswo@users.noreply.github.com> Sat Sep 20 12:52:29 2025 +0900
committer GitHub <noreply@github.com> Sat Sep 20 11:52:29 2025 +0800
tree 889ddf793e70070fb7b9feb8e7f11de5a40bbe43
parent 57e9f98e156186d62e43a9fec19e0a8d49690102

MINOR: Optimize map lookup efficiency with getOrDefault (#20229)

Optimized `getRemainingRecords()` method by replacing inefficient
`containsKey() + get()` pattern with `getOrDefault()` to reduce map
lookups from 2 to 1 per partition.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>

examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java

diff --git a/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java b/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
index 175385b..d424952 100644
--- a/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
+++ b/examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java
@@ -216,11 +216,7 @@
         }
         return consumer.assignment().stream().mapToLong(partition -> {
             long currentPosition = consumer.position(partition);
-            if (fullEndOffsets.containsKey(partition)) {
-                return fullEndOffsets.get(partition) - currentPosition;
-            } else {
-                return 0;
-            }
+            return fullEndOffsets.getOrDefault(partition, currentPosition) - currentPosition;
         }).sum();
     }