Skip to content

Commit 90f8fea

Browse files
committed
BE: Fixed connector topics result
1 parent c7b7b72 commit 90f8fea

File tree

1 file changed

+2
-7
lines changed

1 file changed

+2
-7
lines changed

api/src/main/java/io/kafbat/ui/service/KafkaConnectService.java

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -237,13 +237,8 @@ public Mono<ConnectorDTO> getConnector(KafkaCluster cluster, String connectName,
237237
.map(connectorStatus -> {
238238
var status = connectorStatus.getConnector();
239239
var sanitizedConfig = kafkaConfigSanitizer.sanitizeConnectorConfig(connector.getConfig());
240-
ConnectorDTO result = new ConnectorDTO()
241-
.connect(connectName)
242-
.status(kafkaConnectMapper.fromClient(status))
243-
.type(connector.getType())
244-
.tasks(connector.getTasks())
245-
.name(connector.getName())
246-
.config(sanitizedConfig);
240+
ConnectorDTO result = connector.config(sanitizedConfig)
241+
.status(kafkaConnectMapper.fromClient(status));
247242

248243
if (connectorStatus.getTasks() != null) {
249244
boolean isAnyTaskFailed = connectorStatus.getTasks().stream()

0 commit comments

Comments
 (0)