[fix] [broker] Fix typo in CompactedTopicImpl. (apache#22235)

streamnative · Mar 13, 2024 · 55625d9 · 55625d9
1 parent 7a4e16a
commit 55625d9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java
@@ -62,7 +62,7 @@
 public class CompactedTopicImpl implements CompactedTopic {
     static final long NEWER_THAN_COMPACTED = -0xfeed0fbaL;
     static final long COMPACT_LEDGER_EMPTY = -0xfeed0fbbL;
-    static final int DEFAULT_STARTPOINT_CACHE_SIZE = 100;
+    static final int DEFAULT_MAX_CACHE_SIZE = 100;
 
     private final BookKeeper bk;
 
@@ -254,7 +254,7 @@ private static CompletableFuture<CompactedTopicContext> openCompactedLedger(Book
                                }
                            }, null);
         return promise.thenApply((ledger) -> new CompactedTopicContext(
-                                         ledger, createCache(ledger, DEFAULT_STARTPOINT_CACHE_SIZE)));
+                                         ledger, createCache(ledger, DEFAULT_MAX_CACHE_SIZE)));
     }
 
     private static CompletableFuture<Void> tryDeleteCompactedLedger(BookKeeper bk, long id) {