File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
api/src/main/java/io/kafbat/ui/controller Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change 33import static io .kafbat .ui .model .ConnectorActionDTO .RESTART ;
44import static io .kafbat .ui .model .ConnectorActionDTO .RESTART_ALL_TASKS ;
55import static io .kafbat .ui .model .ConnectorActionDTO .RESTART_FAILED_TASKS ;
6+ import static io .kafbat .ui .model .rbac .permission .ConnectAction .RESET_OFFSETS ;
7+ import static io .kafbat .ui .model .rbac .permission .ConnectAction .VIEW ;
68
79import io .kafbat .ui .api .KafkaConnectApi ;
810import io .kafbat .ui .model .ConnectDTO ;
@@ -290,13 +292,10 @@ private Comparator<FullConnectorInfoDTO> getConnectorsComparator(ConnectorColumn
290292 public Mono <ResponseEntity <Void >> resetConnectorOffsets (String clusterName , String connectName ,
291293 String connectorName ,
292294 ServerWebExchange exchange ) {
293- ConnectAction [] connectActions ;
294-
295- connectActions = new ConnectAction [] { ConnectAction .VIEW , ConnectAction .RESET_OFFSETS };
296295
297296 var context = AccessContext .builder ()
298297 .cluster (clusterName )
299- .connectActions (connectName , connectActions )
298+ .connectActions (connectName , VIEW , RESET_OFFSETS )
300299 .operationName ("resetConnectorOffsets" )
301300 .operationParams (Map .of (CONNECTOR_NAME , connectorName ))
302301 .build ();
You can’t perform that action at this time.
0 commit comments