diff --git a/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java b/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
index 3b1c86a68c285..c19a8acd4b71f 100644
--- a/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
+++ b/pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java
@@ -441,6 +441,15 @@ public void start(boolean blocking) throws Exception {
             String serviceUrl = DEFAULT_SERVICE_URL;
             if (brokerServiceUrl != null) {
                 serviceUrl = brokerServiceUrl;
+            } else {
+                if (sourceConfig != null && sourceConfig.getConfigs() != null
+                        && sourceConfig.getConfigs().get("pulsar.service.url") != null) {
+                    serviceUrl = (String) sourceConfig.getConfigs().get("pulsar.service.url");
+                }
+                if (sinkConfig != null && sinkConfig.getConfigs() != null
+                        && sinkConfig.getConfigs().get("pulsar.service.url") != null) {
+                    serviceUrl = (String) sinkConfig.getConfigs().get("pulsar.service.url");
+                }
             }
             if (webServiceUrl == null) {
                 webServiceUrl = DEFAULT_WEB_SERVICE_URL;