revert formatting changes to the controller

Author: Dugong42

api/src/main/java/io/kafbat/ui/controller/KafkaConnectController.java

@@ -61,8 +61,7 @@ public Mono<ResponseEntity<Flux<String>>> getConnectors(String clusterName, Stri
         .build();
 
     return validateAccess(context)
-        .thenReturn(
-            ResponseEntity.ok(kafkaConnectService.getConnectorNames(getCluster(clusterName), connectName)))
+        .thenReturn(ResponseEntity.ok(kafkaConnectService.getConnectorNames(getCluster(clusterName), connectName)))
         .doOnEach(sig -> audit(context, sig));
   }
 
@@ -177,9 +176,9 @@ public Mono<ResponseEntity<ConnectorDTO>> setConnectorConfig(String clusterName,
         .build();
 
     return validateAccess(context).then(
-        kafkaConnectService
-            .setConnectorConfig(getCluster(clusterName), connectName, connectorName, requestBody)
-            .map(ResponseEntity::ok))
+            kafkaConnectService
+                .setConnectorConfig(getCluster(clusterName), connectName, connectorName, requestBody)
+                .map(ResponseEntity::ok))
         .doOnEach(sig -> audit(context, sig));
   }
 
@@ -205,8 +204,8 @@ public Mono<ResponseEntity<Void>> updateConnectorState(String clusterName, Strin
     return validateAccess(context).then(
         kafkaConnectService
             .updateConnectorState(getCluster(clusterName), connectName, connectorName, action)
-            .map(ResponseEntity::ok))
-        .doOnEach(sig -> audit(context, sig));
+            .map(ResponseEntity::ok)
+    ).doOnEach(sig -> audit(context, sig));
   }
 
   @Override
@@ -224,8 +223,8 @@ public Mono<ResponseEntity<Flux<TaskDTO>>> getConnectorTasks(String clusterName,
     return validateAccess(context).thenReturn(
         ResponseEntity
             .ok(kafkaConnectService
-                .getConnectorTasks(getCluster(clusterName), connectName, connectorName)))
-        .doOnEach(sig -> audit(context, sig));
+                .getConnectorTasks(getCluster(clusterName), connectName, connectorName))
+    ).doOnEach(sig -> audit(context, sig));
   }
 
   @Override
@@ -243,8 +242,8 @@ public Mono<ResponseEntity<Void>> restartConnectorTask(String clusterName, Strin
     return validateAccess(context).then(
         kafkaConnectService
             .restartConnectorTask(getCluster(clusterName), connectName, connectorName, taskId)
-            .map(ResponseEntity::ok))
-        .doOnEach(sig -> audit(context, sig));
+            .map(ResponseEntity::ok)
+    ).doOnEach(sig -> audit(context, sig));
   }
 
   @Override
@@ -260,8 +259,8 @@ public Mono<ResponseEntity<Flux<ConnectorPluginDTO>>> getConnectorPlugins(
     return validateAccess(context).then(
         Mono.just(
             ResponseEntity.ok(
-                kafkaConnectService.getConnectorPlugins(getCluster(clusterName), connectName))))
-        .doOnEach(sig -> audit(context, sig));
+                kafkaConnectService.getConnectorPlugins(getCluster(clusterName), connectName)))
+    ).doOnEach(sig -> audit(context, sig));
   }
 
   @Override