Merge pull request #77 from Landoop/fix-for-sing-kafka-1.1

Fix for Sink connectors valiation for kafka 1.1

Author: jglambed

src/kafka-connect/create-connector/create-connector.controller.js

@@ -191,6 +191,9 @@ angularAPP.controller('CreateConnectorCtrl', function ($scope, $rootScope, $http
        headers: {'Content-Type': 'application/json', 'Accept': 'application/json'}
     };
 
+    if(connector.type === 'Sink'){
+      request.data = '{ "connector.class" : "' + pluginClass + '", "topics" : "TopicName_'+ connector.name +'" }'
+    }
     $http(request).then(function(data){
     angular.forEach(data.data.configs, function (config) {