[improve][broker] Improve the extensibility of the TopicBundleAssignm…

…entStrategy interface class (#23773)
apache · Jan 10, 2025 · 04423ba · 04423ba
1 parent b8efc53
commit 04423ba
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/...r/src/main/java/org/apache/pulsar/common/naming/ConsistentHashingTopicBundleAssigner.java b/...r/src/main/java/org/apache/pulsar/common/naming/ConsistentHashingTopicBundleAssigner.java
@@ -28,8 +28,6 @@
 public class ConsistentHashingTopicBundleAssigner implements TopicBundleAssignmentStrategy {
     private PulsarService pulsar;
 
-    private volatile HashFunction hashFunction;
-
     @Override
     public NamespaceBundle findBundle(TopicName topicName, NamespaceBundles namespaceBundles) {
         NamespaceBundle bundle = namespaceBundles.getBundle(calculateBundleHashCode(topicName));
@@ -41,10 +39,7 @@ public NamespaceBundle findBundle(TopicName topicName, NamespaceBundles namespac
 
     @Override
     public long calculateBundleHashCode(TopicName topicName) {
-        if (hashFunction == null) {
-            hashFunction = getBundleHashFunc();
-        }
-        return hashFunction.hashString(topicName.toString(), StandardCharsets.UTF_8).padToLong();
+        return getBundleHashFunc().hashString(topicName.toString(), StandardCharsets.UTF_8).padToLong();
     }
 
     @Override