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 f85afe0cc7214..a835f2334b388 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 @@ -824,14 +824,15 @@ public void start() throws PulsarServerException { acquireSLANamespace(); - // start function worker service if necessary - this.startWorkerService(brokerService.getAuthenticationService(), brokerService.getAuthorizationService()); // start packages management service if necessary if (config.isEnablePackagesManagement()) { this.startPackagesManagementService(); } + // start function worker service if necessary + this.startWorkerService(brokerService.getAuthenticationService(), brokerService.getAuthorizationService()); + // Start the task to publish resource usage, if necessary this.resourceUsageTransportManager = DISABLE_RESOURCE_USAGE_TRANSPORT_MANAGER; if (isNotBlank(config.getResourceUsageTransportClassName())) {