我有一个项目要求，我应该通过给定的示例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");

我得到一个未知主机异常。
有谁能帮我扭转网址的方式，我可以成功地开始接收我的应用程序中的事件。
或
在flink中是否还有其他用于处理事件的函数？