@@ -207,22 +207,13 @@ public Mono<Void> deleteConnector(
207207 public Mono <Void > updateConnectorState (KafkaCluster cluster , String connectName ,
208208 String connectorName , ConnectorActionDTO action ) {
209209 return api (cluster , connectName )
210- .mono (client -> {
211- switch (action ) {
212- case RESTART :
213- return client .restartConnector (connectorName , false , false );
214- case RESTART_ALL_TASKS :
215- return restartTasks (cluster , connectName , connectorName , task -> true );
216- case RESTART_FAILED_TASKS :
217- return restartTasks (cluster , connectName , connectorName ,
218- t -> t .getStatus ().getState () == ConnectorTaskStatusDTO .FAILED );
219- case PAUSE :
220- return client .pauseConnector (connectorName );
221- case RESUME :
222- return client .resumeConnector (connectorName );
223- default :
224- throw new IllegalStateException ("Unexpected value: " + action );
225- }
210+ .mono (client -> switch (action ) {
211+ case RESTART -> client .restartConnector (connectorName , false , false );
212+ case RESTART_ALL_TASKS -> restartTasks (cluster , connectName , connectorName , task -> true );
213+ case RESTART_FAILED_TASKS -> restartTasks (cluster , connectName , connectorName ,
214+ t -> t .getStatus ().getState () == ConnectorTaskStatusDTO .FAILED );
215+ case PAUSE -> client .pauseConnector (connectorName );
216+ case RESUME -> client .resumeConnector (connectorName );
226217 });
227218 }
228219
0 commit comments