Support Questions

Find answers, ask questions, and share your expertise
Check out our newest addition to the community, the Cloudera Data Analytics (CDA) group hub.

ConnectWebSocket Usage

New Contributor


It seems I am missing something about the ConnectWebSocket processor. How can I pass data to the PutWebSocket processor and include the (mandatory) websocket.* attributes generated by ConnectWebSocket? Please mind that the ConnectWebSocket processor does not allow incoming relationships. Currently, I am getting the error "Required WebSocket attribute was not found.", as is to be expected after reviewing the code. See the attachment for what I am trying to achieve.


Thanks, Joost


Super Guru

PutWebSocket takes a flow file, you can add a replacetext step to build one

Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.