所以，我对我尝试使用的所有 Apache 框架都非常陌生。我希望您对 IoT 流应用程序的几个工作流程设计提出建议：
- 由于我们有可用于 Flink 的 NiFi 连接器，因此我们可以轻松地在 Flink 上使用 Beam 抽象。我可以使用 NiFi 作为数据流工具，将数据从 MiNiFi 驱动到 Flink Cluster（这里将其存储在内存中或其他东西中），然后使用 Beam Pipeline 进一步处理数据。
- 是否有任何用于光束的 NiFi 连接器？如果不能，我们可以这样做吗？因此，我们直接将数据从 NiFi 流式传输到 Beam 作业（在 Flink 集群上运行）
我仍处于早期设计阶段，如果我们可以讨论可能的解决方法，那就太好了。如果您需要任何其他详细信息，请告诉我。