我目前正在一个流媒体平台上工作，它接受来自Kafka的无限流。我使用flink作为我的流处理引擎。我能够成功地接收数据，在事件时间打开窗口，在flink中做任何我想做的事情。此流的输出当前进入kafka接收器，这暂时还可以，因为此数据不会流到任何地方。整个设置部署在aws上。
外部客户机现在对数据感兴趣。客户端希望数据采用流格式，而不是从kafka提取数据。我们也不想把我们的Kafka经纪人暴露给外部世界。我们怎样才能做到这一点？我试着用图钉代理来“推”出数据。然而，这是一个痛苦的设置和管理。
你知道怎么做吗？我真的愿意接受任何想法。
谢谢