控制Apache的卡夫卡和弗林克通过SCALA（而不是命令行）

Question

使用卡夫卡/弗林克命令行 - 在Scala代码“命令”

目前，当我将作业提交到弗林克，其通过命令行。与创建和删除Kafka主题相同。

是否有Scala - 用于控制命令行接口命令执行的API。因此，根据应用程序中的条件，我可以提交作业以链接并从代码创建/删除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

弗林克的REST API可用于submit和cancel工作。

要创建和删除卡夫卡主题，我会看看Kafka's Admin API。

至于用于控制Flink服务的API，您最好等待ongoing work on FLIP-6完成。