Apache Beam的WebSocket连接器（Java）？

Question

我有一个用Java编写的ApacheBeam管道，我想在这里读取来自Websocket的数据

我一直在寻找一些连接器，但到目前为止我的搜索没有成功