From 21a1c3242f0717eef40da8adc05470232c4b604d Mon Sep 17 00:00:00 2001 From: Sehun Shin Date: Tue, 14 Dec 2021 13:58:04 +0900 Subject: [PATCH] Fix connector type checker The connector type can be recognized by `$.type` field Since Kafka 6.2.1 --- src/factories/connector-objects.factory.js | 2 +- src/kafka-connect/cluster-view/cluster-view.controller.js | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/factories/connector-objects.factory.js b/src/factories/connector-objects.factory.js index 8bcd47a..4271dff 100644 --- a/src/factories/connector-objects.factory.js +++ b/src/factories/connector-objects.factory.js @@ -57,7 +57,7 @@ angularAPP.factory('connectorObjects', function (KafkaConnectFactory, supportedC } function isSource(connector) { - return 'Source' === configurationTypeFilter(connector.config); + return 'Source' === configurationTypeFilter(connector.config) || 'source' === connector.type; } function enhanceConnectors(connectors) { diff --git a/src/kafka-connect/cluster-view/cluster-view.controller.js b/src/kafka-connect/cluster-view/cluster-view.controller.js index 1523290..1506fc5 100644 --- a/src/kafka-connect/cluster-view/cluster-view.controller.js +++ b/src/kafka-connect/cluster-view/cluster-view.controller.js @@ -19,7 +19,7 @@ angularAPP.controller('ClusterViewCtrl', function ($scope, $log, $http, env, con var template = connectorObjects.getConnectorTemplate(connector.config); var topics = connectorObjects.getTopics(connector.config); var workers = connector.config["tasks.max"]; - var isSource = template.type == 'Source'; + var isSource = template.type == 'Source' || connector.type === 'source'; var type = template.name; var color = template.color; // var html = createCustomHTMLContent(isSource, workers, type, color);