通过SCALA (非命令行)控制Apache-Kafka和Flink

Question

在SCALA代码中使用Kafka/FLink命令行-“命令”

当前，当我向Flink提交作业时，它通过命令行。与创建和删除卡夫卡主题相同。

是否有一个Scala来控制命令行接口命令的执行.因此，根据应用程序中的条件，我可以向flink提交一个作业，并从代码中创建/删除kafka。

我想在Scala代码中使用的命令

Starting Flink Server
    bin/start-local.sh

Stopping Flink Server
    bin/stop-local.sh

Submitting Job Flink
    bin/flink run -c pathToMainClass pathToJar arg1 arg2

Creating topics in kafka

Deleting kafka topics

Cancelling a job (ID)
...

问候

Answer 1

Flink的REST可以用于提交和取消作业。

对于创建和删除Kafka主题，我将查看卡夫卡的管理API。

至于用于控制Flink服务的API，最好是等待正在进行的翻转工作-6完成。