diff --git a/confluent_server/confluent/httpapi.py b/confluent_server/confluent/httpapi.py index bd7e9764..d2d746fa 100644 --- a/confluent_server/confluent/httpapi.py +++ b/confluent_server/confluent/httpapi.py @@ -381,7 +381,8 @@ def _assign_consessionid(consolesession): 'expiry': time.time() + 60} return sessid -@eventlet.websocket.WebSocketWSGI +@eventlet.websocket.WebSocketWSGI.configured( + supported_protocols=['confluent.console']) def wsock_handler(ws): sessid = ws.wait() sessid = sessid.replace('ConfluentSessionId:', '')