如何创建Spark/Flink流数据处理作为微服务(REST API)

Question

我正在使用Spark，Flink＆amp;创建流分析应用程序卡夫卡。每个分析/功能将作为微服务实现，以便以后能够在不同的项目中使用。

我在简单的Scala应用程序中完美地运行Spark/Flink作业，并通过Spark＆amp;flink群集分别。但是，当REST POST StartJob((请求调用到我的Web服务时，我必须启动/运行此作业。

我如何整合我的火花＆amp;面向Web服务的应用程序中的Flink数据处理功能？

到现在为止

1. 在Lagom Microservice中摄入流数据的最佳方法
2. java.io.notserializable Exception使用Apache Flink with with withlagom

我认为我没有向流处理微服务应用程序迈出正确的方向。寻找正确的方向以通过REST服务实施此分析。

Answer 1

flink具有一个REST API，您可以用来提交和控制作业 - Flink Web UI使用了它。在这里查看文档。另请参阅以前的问题。

Answer 2

我认为REST API提供了作业运行详细信息，任何FLINK API提供假设是否spring boot reter端点呼叫连接KAFKA流媒体数据并返回KAFKA数据？