java使用ApacheFlink为安全websocket（wss）指定socket流源

Question

我有一个项目要求，我应该通过给定的示例api（这是一个篡改的url）定期流式传输事件：

wss://brisbane.unipulse.com.au:443/OutboundInterfaces/outbound/statements

但是，在尝试使用该功能时：

    DataStream<String> text = env.socketTextStream("wss://brisbane.unipulse.com.au:443/OutboundInterfaces/outbound/statements", port, "\n");

我得到一个未知主机异常

任何人都可以帮助我扭转的方式，我可以成功地开始接收我的应用程序中的事件的url

或

在flink中是否有其他用于处理事件的函数