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

Question

Using Kafka/FLink 命令行 - SCALA Code 中的"命令"

目前，当我向 Flink 提交作业时，它是通过命令行进行的。与创建和删除 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

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

对于创建和删除 Kafka 主题，我会查看 Kafka 的 Admin API。

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