diff --git a/alpaca_trade_api/stream.py b/alpaca_trade_api/stream.py
index b6c206e4..e1d28319 100644
--- a/alpaca_trade_api/stream.py
+++ b/alpaca_trade_api/stream.py
@@ -464,7 +464,7 @@ def __init__(self,
         self._key_id = key_id
         self._secret_key = secret_key
         base_url = re.sub(r'^http', 'ws', base_url)
-        endpoint = base_url + '/v1beta2/crypto'
+        endpoint = base_url + '/v1beta3/crypto/us'
         if exchanges:
             if isinstance(exchanges, str):
                 endpoint += '?exchanges=' + exchanges