flink stream api sockettextstream(主机名,端口(方法充当客户端。也就是说,我们需要在端口上发送连续流," sockettextstream(主机名,端口("方法将读取传入流。
但是我的要求就像,我想将Flink用作服务器,并寻找可以从端口收听的API。任何人都可以有弗林克流动脉api吗?那将解决我的问题。预先感谢!!!
//
没有对flink内置的支持,但是如果您真的想使用,则可以将服务器构建到flatmap运算符或ProcessFunction,或者实现自定义槽。
但是,这似乎不是构建强大系统的好方法(使这种可容纳耐受性或在没有数据丢失的情况下管理重新部署并不容易(。为什么不将Flink的结果流式传输到Kafka主题之类的内容,然后将其他客户附加到那里?