Skip to content

Commit 2f341ac

Browse files
committed
Fix for supporting 3.2 APIs
1 parent 1b50c40 commit 2f341ac

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -178,7 +178,7 @@ angularAPP.controller('CreateConnectorCtrl', function ($scope, $rootScope, $http
178178
var request = {
179179
method: 'PUT',
180180
url: env.KAFKA_CONNECT() + '/connector-plugins/' + pluginClass + '/config/validate',
181-
data: '{}',
181+
data: '{ "connector.class" : "' + pluginClass + '" }',
182182
dataType: 'json',
183183
headers: {'Content-Type': 'application/json', 'Accept': 'application/json'}
184184
};
@@ -217,7 +217,7 @@ $scope.getAllConfig = function (pluginClass){
217217
var request = {
218218
method: 'PUT',
219219
url: env.KAFKA_CONNECT() + '/connector-plugins/' + pluginClass + '/config/validate',
220-
data: '{}',
220+
data: '{ "connector.class" : "' + pluginClass + '" }',
221221
dataType: 'json',
222222
headers: {'Content-Type': 'application/json', 'Accept': 'application/json'}
223223
};

0 commit comments

Comments
 (0)