所以，我对我尝试使用的所有apache框架都非常陌生。我想听听你对物联网流媒体应用程序的几个工作流设计的建议：
因为我们有nifi连接器可用于flink，我们可以很容易地在flink上使用束流抽象。我可以使用nifi作为数据流工具将数据从minifi驱动到flink集群（这里将其存储在内存或其他东西中），然后使用beam pipeline进一步处理数据。
光束是否有nifi连接器？如果不行，我们能这样做吗？因此，我们直接将数据从nifi流式传输到beam作业（在flink集群上运行）
我还处于早期设计阶段，如果我们能讨论可能的解决方法，那就太好了。如果你需要任何其他细节，请告诉我。