SCALAによる支配のApache-カフカとFLINK（未コマンドライン）

Question

。カフカトピックの作成と削除と同じです。

コマンドラインインターフェイスコマンドの実行を制御するための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) 
... 

よろしくで使用したい

FLINKのREST APIが submitと cancelジョブに使用することができます

Answer 1

。

カフカトピックの作成と削除については、Kafka's Admin APIをご覧ください。

Flinkのサービスを制御するAPIについては、ongoing work on FLIP-6が完了するのを待つ方がよい場合があります。