Add setNamespaceBundleAffinity method

apache · Jan 17, 2023 · 3765839 · 3765839
1 parent 51be8fb
commit 3765839
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...in/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java b/...in/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java
@@ -88,6 +88,12 @@ public CompletableFuture<Set<String>> getAvailableBrokersAsync() {
         return this.loadManager.getBrokerRegistry().getAvailableBrokersAsync().thenApply(HashSet::new);
     }
 
+    @Override
+    public String setNamespaceBundleAffinity(String bundle, String broker) {
+        // TODO: Add namespace bundle affinity support.
+        return null;
+    }
+
     @Override
     public void stop() throws PulsarServerException {
         this.loadManager.close();