diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/KafkaConnectController.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/KafkaConnectController.java index 080c6020f9..d300b93016 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/KafkaConnectController.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/controller/KafkaConnectController.java @@ -211,7 +211,7 @@ public class KafkaConnectController extends AbstractController implements KafkaC Mono validateAccess = accessControlService.validateAccess(AccessContext.builder() .cluster(clusterName) .connect(connectName) - .connectActions(ConnectAction.VIEW, ConnectAction.EDIT) + .connectActions(ConnectAction.VIEW, ConnectAction.RESTART) .build()); return validateAccess.then( diff --git a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/rbac/permission/ConnectAction.java b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/rbac/permission/ConnectAction.java index 3db4d4953c..1c3335e360 100644 --- a/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/rbac/permission/ConnectAction.java +++ b/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/rbac/permission/ConnectAction.java @@ -7,7 +7,8 @@ public enum ConnectAction implements PermissibleAction { VIEW, EDIT, - CREATE + CREATE, + RESTART ;