Contrôle Apache Kafka et Flink par SCALA (Non ligne de commande)

Question

en ligne de commande Kafka/Flink - « commandes » dans SCALA code

À l'heure actuelle Quand je soumettre des travaux à Flink, son via la ligne de commande. Idem que pour créer et supprimer des sujets Kafka.

Existe-t-il une API Scala pour contrôler l'exécution des commandes d'interface de ligne de commande? Donc, basé sur une condition dans une application, je peux soumettre un travail à flinker et créer/supprimer kafka du code.

Commandes Je voudrais utiliser dans le code 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) 
... 

Cordialement

Answer 1

REST API de Flink peut être utilisé pour des emplois submit et cancel. Pour créer et supprimer des sujets Kafka, je regarderais Kafka's Admin API. En ce qui concerne les API pour le contrôle des services de Flink, il vaut peut-être mieux attendre que le ongoing work on FLIP-6 soit terminé.