Merge pull request #72 from asdf2014/restart_task

Add new feature: restart task

Author: jglambed

src/factories/kafka-connect-api.factory.js

@@ -73,6 +73,10 @@ angularAPP.service('KafkaConnectFactory', function ($rootScope, $http, $location
       var url = env.KAFKA_CONNECT() + '/connectors/' + connectorName + "/restart";
       return req('POST', url);
     },
+    restartTask: function (connectorName, taskId) {
+      var url = env.KAFKA_CONNECT() + '/connectors/' + connectorName + '/tasks/' + taskId + "/restart";
+      return req('POST', url);
+    },
     pauseConnector: function (connectorName) {
       var url = env.KAFKA_CONNECT() + '/connectors/' + connectorName + "/pause";
       return req('PUT', url);

src/kafka-connect/view/connector-view.html

@@ -85,6 +85,7 @@ <h4 style="margin-top: 0px;width:70px"><i class="grey" aria-hidden="true"></i> T
     </div>
     <div ng-if="selectedTask" style="font-size:11px;padding-left: 10px;border: 1px solid #ccc;margin-top: -5px;margin-left: 70px;margin-bottom: 10px;width:90%">
       <md-button class="md-mini md-primary" ng-click="invalidateSelectedTask()" style="color:black;float:right;margin:0;">close</md-button>
+      <md-button class="md-mini md-primary" ng-click="restartTask(connectorDetails.name, selectedTask.taskStatus.id);" style="color:black;float:right;margin:0;">restart</md-button>
 
       <h5 style="margin-top:5px;margin-bottom:5px;">Task {{selectedTask.taskStatus.id}} is {{selectedTask.taskStatus.state}}</h5>
       <!--<h5 ng-if="selectedTask.taskStatus.state != 'UNASSIGNED'">CONFIG:</h5>-->

src/kafka-connect/view/view.controller.js

@@ -57,6 +57,11 @@ angularAPP.controller('ConnectorDetailCtrl', function ($rootScope, $scope, $rout
     $rootScope.newConnectorChanges = true;
   };
 
+  $scope.restartTask = function (connectorName, taskId) {
+    KafkaConnectFactory.restartTask(connectorName, taskId).then(function(data) { init(); });
+    $rootScope.newConnectorChanges = true;
+  };
+
   $scope.updateConnector = function (connectorName, event, _editor) {
     $mdDialog.show(dialog('UPDATE', event)).then(function() {
         $scope.invalidateSelectedTask();