У меня есть конвейер Apache Beam, написанный на Java, где я хотел бы прочитать данные, поступающие из Websocket.
Я искал некоторые соединители, но пока мой поиск не удался.