diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
index b23851a5ec464..060e905d1f3c5 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java
@@ -2016,7 +2016,7 @@ protected BrokerService newBrokerService(PulsarService pulsar) throws Exception
     }
 
     @VisibleForTesting
-    public void setTransactionExecutorProvider(TransactionBufferProvider transactionBufferProvider) {
+    public void setTransactionBufferProvider(TransactionBufferProvider transactionBufferProvider) {
         this.transactionBufferProvider = transactionBufferProvider;
     }
 
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
index d6473efd788d8..b5af3cc6afd6c 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/OrphanPersistentTopicTest.java
@@ -152,7 +152,7 @@ public CompletableFuture<Void> closeAsync() {
             }
         };
         TransactionBufferProvider originalTransactionBufferProvider = pulsar.getTransactionBufferProvider();
-        pulsar.setTransactionExecutorProvider(mockTransactionBufferProvider);
+        pulsar.setTransactionBufferProvider(mockTransactionBufferProvider);
         CompletableFuture<Optional<Topic>> firstLoad = pulsar.getBrokerService().getTopic(tpName, true);
         Awaitility.await().ignoreExceptions().atMost(5, TimeUnit.SECONDS)
                 .pollInterval(100, TimeUnit.MILLISECONDS)
@@ -170,7 +170,7 @@ public CompletableFuture<Void> closeAsync() {
         }
 
         // set to back
-        pulsar.setTransactionExecutorProvider(originalTransactionBufferProvider);
+        pulsar.setTransactionBufferProvider(originalTransactionBufferProvider);
         pulsar.getConfig().setTopicLoadTimeoutSeconds(originalTopicLoadTimeoutSeconds);
         pulsar.getConfig().setBrokerDeduplicationEnabled(false);
         pulsar.getConfig().setTransactionCoordinatorEnabled(false);