Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Configuring authorization parameters with JettyWebSocketClient

Highlighted

Configuring authorization parameters with JettyWebSocketClient

New Contributor

I have a requirement to establish connection with websocket using JettyWebSocketClient controller in Nifi.

I need to pass authorization parameters as header to establish valid session with web socket.

Example python code that works is as below

ws = websocket.WebSocketApp("wss://<domain/url>/api-ws/v1/stream",header=['Authorization: Basic %s' % base64.encodestring(email + ':' + password)],on_message=on_message,on_error=on_error,on_close=on_close

I am unable to figure out how to add the header attribute to JettyWebSocketClient configuration for establishing valid session with web socket. Can I get some help to understand if my case can be fulfilled with nifi JettyWebSocketClient controller.