fix Kinesis server access

alexrashed · alexrashed · commit 198b4d4e0867 · 2022-08-30T11:32:56.000+02:00
diff --git a/localstack/services/kinesis/kinesis_starter.py b/localstack/services/kinesis/kinesis_starter.py
@@ -81,3 +81,7 @@ def is_kinesis_running() -> bool:
     if _server is None:
         return False
     return _server.is_running()
+
+
+def get_server():
+    return _server
diff --git a/localstack/services/kinesis/provider.py b/localstack/services/kinesis/provider.py
@@ -91,7 +91,7 @@ def on_before_start(self):
 
     def get_forward_url(self):
         """Return the URL of the backend Kinesis server to forward requests to"""
-        return f"http://{LOCALHOST}:{starter._server.port}"
+        return f"http://{LOCALHOST}:{starter.get_server().port}"
 
     def subscribe_to_shard(
         self,
