Minor refactor

apache · Nov 15, 2024 · 7c935b1 · 7c935b1
1 parent 60974e0
commit 7c935b1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/kafka/server/share/SharePartition.java b/core/src/main/java/kafka/server/share/SharePartition.java
@@ -1596,7 +1596,7 @@ private Optional<Throwable> acknowledgeCompleteBatch(
     protected void updateFetchOffsetMetadata(long nextFetchOffset, LogOffsetMetadata logOffsetMetadata) {
         lock.writeLock().lock();
         try {
-            fetchOffsetMetadata.updateFetchOffsetMetadata(nextFetchOffset, logOffsetMetadata);
+            fetchOffsetMetadata.updateOffsetMetadata(nextFetchOffset, logOffsetMetadata);
         } finally {
             lock.writeLock().unlock();
         }
@@ -2440,7 +2440,7 @@ LogOffsetMetadata offsetMetadata() {
             return offsetMetadata;
         }
 
-        void updateFetchOffsetMetadata(long offset, LogOffsetMetadata offsetMetadata) {
+        void updateOffsetMetadata(long offset, LogOffsetMetadata offsetMetadata) {
             this.offset = offset;
             this.offsetMetadata = offsetMetadata;
         }