0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

When restart failed, error msg pop up

Browse source
This commit is contained in:
Junseok-Hur 2023-05-08 21:51:26 -04:00
parent 943b4075f6
commit 1f958ee3b0
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
kafka-ui-api/src/main/java/com/provectus/kafka/ui/service/KafkaConnectService.java
View file

@ -265,8 +265,9 @@ public class KafkaConnectService {
String connectorName, Predicate<TaskDTO> taskFilter) {
return getConnectorTasks(cluster, connectName, connectorName)
.filter(taskFilter)
.flatMap(t ->
restartConnectorTask(cluster, connectName, connectorName, t.getId().getTask()))
.flatMap(t -> restartConnectorTask(cluster, connectName, connectorName, t.getId().getTask())
.onErrorResume(e -> Mono.error(new RuntimeException("Failed to restart task", e)))
)
.then();
}