Clean code

Author: magnusdriver

api/src/main/java/io/kafbat/ui/service/KafkaClusterFactory.java

@@ -167,12 +167,9 @@ private boolean schemaRegistryConfigured(ClustersProperties.Cluster clusterPrope
   }
 
   private ReactiveFailover<KafkaSrClientApi> schemaRegistryClient(ClustersProperties.Cluster clusterProperties) {
-
-
-    //System.out.println("Creating Schema Registry Client for cluster: " + clusterProperties.getName());
+    
     var auth = Optional.ofNullable(clusterProperties.getSchemaRegistryAuth())
         .orElse(new ClustersProperties.SchemaRegistryAuth());
-    //System.out.println("Auth details: " + auth.toString());
     WebClient webClient = new WebClientConfigurator()
         .configureSsl(clusterProperties.getSsl(), clusterProperties.getSchemaRegistrySsl())
         .configureBasicAuth(auth.getUsername(), auth.getPassword())

api/src/main/java/io/kafbat/ui/util/WebClientConfigurator.java

@@ -19,7 +19,6 @@
 import javax.annotation.Nullable;
 import javax.net.ssl.KeyManagerFactory;
 import javax.net.ssl.TrustManagerFactory;
-import javax.validation.constraints.Null;
 import lombok.SneakyThrows;
 import org.openapitools.jackson.nullable.JsonNullableModule;
 import org.springframework.http.MediaType;
@@ -58,8 +57,6 @@ private static ObjectMapper defaultOM() {
   }
 
   public WebClientConfigurator configureBearerTokenAuth(@Nullable String bearerAuthCustomProviderClass) {
-    //System.out.println("Configuring GCP Bearer Auth in web client");
-    //System.out.println("Bearer Auth Custom Provider Class: " + bearerAuthCustomProviderClass);
     if (Objects.equals(bearerAuthCustomProviderClass, GCP_BEARER_AUTH_CUSTOM_PROVIDER_CLASS)) {
       builder.filter(createGcpBearerAuthFilter());
     }