diff --git a/kinesis-to-http/kinesis-forwarder-staging.py b/kinesis-to-http/eras_forwarder.py
similarity index 92%
rename from kinesis-to-http/kinesis-forwarder-staging.py
rename to kinesis-to-http/eras_forwarder.py
index 7e96ad8..90ff196 100644
--- a/kinesis-to-http/kinesis-forwarder-staging.py
+++ b/kinesis-to-http/eras_forwarder.py
@@ -5,7 +5,7 @@
 from requests.auth import HTTPBasicAuth
 
 HEADERS  = {"Content-Type": "application/json", "Accept": "application/json"}
-ENDPOINT = "https://eras-staging.zooniverse.org/kinesis"
+ENDPOINT = os.environ["KINESIS_STREAM_ENDPOINT"]
 
 def lambda_handler(event, context):
     payloads = [json.loads(base64.b64decode(record["kinesis"]["data"])) for record in event["Records"]]