Spotless code style changes

Author: rozza

src/integrationTest/java/com/mongodb/kafka/connect/ConnectorValidationTest.java

@@ -43,99 +43,104 @@
 
 class ConnectStandalone {
 
-    private static final Logger LOGGER = LoggerFactory.getLogger(ConnectStandalone.class);
-
-    private final String connectionString;
-    private final Herder herder;
-    private final Connect connect;
-
-    @SuppressWarnings("unchecked")
-    ConnectStandalone(final Properties workerProperties) {
-        Time time = Time.SYSTEM;
-        LOGGER.info("Kafka Connect standalone worker initializing ...");
-        long initStart = time.hiResClockMs();
-        WorkerInfo initInfo = new WorkerInfo();
-        initInfo.logAll();
-
-        Map<String, String> workerProps = (Map) workerProperties;
-
-        LOGGER.info("Scanning for plugin classes. This might take a moment ...");
-        Plugins plugins = new Plugins(workerProps);
-        plugins.compareAndSwapWithDelegatingLoader();
-        StandaloneConfig config = new StandaloneConfig(workerProps);
-
-        String kafkaClusterId = ConnectUtils.lookupKafkaClusterId(config);
-        LOGGER.debug("Kafka cluster ID: {}", kafkaClusterId);
-
-        RestServer rest = new RestServer(config);
-        URI advertisedUrl = rest.advertisedUrl();
-        String workerId = advertisedUrl.getHost() + ":" + advertisedUrl.getPort();
-
-        Worker worker = new Worker(workerId, time, plugins, config, new FileOffsetBackingStore());
-        this.herder = new StandaloneHerder(worker, kafkaClusterId);
-        connectionString = advertisedUrl.toString() + herder.kafkaClusterId();
-
-        this.connect = new Connect(herder, rest);
-        LOGGER.info("Kafka Connect standalone worker initialization took {}ms", time.hiResClockMs() - initStart);
-    }
-
-    String getConnectionString() {
-        return connectionString;
-    }
-
-    void start() {
-        connect.start();
-    }
-
-    @SuppressWarnings({"unchecked", "rawtypes"})
-    void addConnector(final String name, final Properties properties) {
-        FutureCallback<Herder.Created<ConnectorInfo>> cb = new FutureCallback<>((error, info) -> {
-            if (error != null) {
+  private static final Logger LOGGER = LoggerFactory.getLogger(ConnectStandalone.class);
+
+  private final String connectionString;
+  private final Herder herder;
+  private final Connect connect;
+
+  @SuppressWarnings("unchecked")
+  ConnectStandalone(final Properties workerProperties) {
+    Time time = Time.SYSTEM;
+    LOGGER.info("Kafka Connect standalone worker initializing ...");
+    long initStart = time.hiResClockMs();
+    WorkerInfo initInfo = new WorkerInfo();
+    initInfo.logAll();
+
+    Map<String, String> workerProps = (Map) workerProperties;
+
+    LOGGER.info("Scanning for plugin classes. This might take a moment ...");
+    Plugins plugins = new Plugins(workerProps);
+    plugins.compareAndSwapWithDelegatingLoader();
+    StandaloneConfig config = new StandaloneConfig(workerProps);
+
+    String kafkaClusterId = ConnectUtils.lookupKafkaClusterId(config);
+    LOGGER.debug("Kafka cluster ID: {}", kafkaClusterId);
+
+    RestServer rest = new RestServer(config);
+    URI advertisedUrl = rest.advertisedUrl();
+    String workerId = advertisedUrl.getHost() + ":" + advertisedUrl.getPort();
+
+    Worker worker = new Worker(workerId, time, plugins, config, new FileOffsetBackingStore());
+    this.herder = new StandaloneHerder(worker, kafkaClusterId);
+    connectionString = advertisedUrl.toString() + herder.kafkaClusterId();
+
+    this.connect = new Connect(herder, rest);
+    LOGGER.info(
+        "Kafka Connect standalone worker initialization took {}ms",
+        time.hiResClockMs() - initStart);
+  }
+
+  String getConnectionString() {
+    return connectionString;
+  }
+
+  void start() {
+    connect.start();
+  }
+
+  @SuppressWarnings({"unchecked", "rawtypes"})
+  void addConnector(final String name, final Properties properties) {
+    FutureCallback<Herder.Created<ConnectorInfo>> cb =
+        new FutureCallback<>(
+            (error, info) -> {
+              if (error != null) {
                 LOGGER.error("Failed to create job for {}", properties);
-            } else {
+              } else {
                 LOGGER.info("Created connector {}", info.result().name());
-            }
-        });
-        try {
-            herder.putConnectorConfig(name, (Map) properties, true, cb);
-            cb.get();
-            sleep(1000);
-        } catch (Exception e) {
-            LOGGER.error("Failed to add connector for {}", properties);
-            throw new ConnectorConfigurationException(e);
-        }
+              }
+            });
+    try {
+      herder.putConnectorConfig(name, (Map) properties, true, cb);
+      cb.get();
+      sleep(1000);
+    } catch (Exception e) {
+      LOGGER.error("Failed to add connector for {}", properties);
+      throw new ConnectorConfigurationException(e);
     }
+  }
 
-    void deleteConnector(final String name) {
-        FutureCallback<Herder.Created<ConnectorInfo>> cb = new FutureCallback<>((error, info) -> {
-            if (error != null) {
+  void deleteConnector(final String name) {
+    FutureCallback<Herder.Created<ConnectorInfo>> cb =
+        new FutureCallback<>(
+            (error, info) -> {
+              if (error != null) {
                 LOGGER.error("Failed to delete connector: {}", name);
-            } else {
+              } else {
                 LOGGER.info("Deleted connector {}", name);
-            }
-        });
-        try {
-            herder.deleteConnectorConfig(name, cb);
-            cb.get();
-        } catch (NotFoundException e) {
-            // Ignore
-        } catch (Exception e) {
-            if (!(e.getCause() instanceof NotFoundException)) {
-                throw new ConnectorConfigurationException(e);
-            }
-        }
+              }
+            });
+    try {
+      herder.deleteConnectorConfig(name, cb);
+      cb.get();
+    } catch (NotFoundException e) {
+      // Ignore
+    } catch (Exception e) {
+      if (!(e.getCause() instanceof NotFoundException)) {
+        throw new ConnectorConfigurationException(e);
+      }
     }
+  }
 
-    void stop() {
-        LOGGER.debug("Connect Standalone stop called");
-        connect.stop();
-        connect.awaitStop();
-    }
+  void stop() {
+    LOGGER.debug("Connect Standalone stop called");
+    connect.stop();
+    connect.awaitStop();
+  }
 
-    class ConnectorConfigurationException extends RuntimeException {
-        ConnectorConfigurationException(final Throwable cause) {
-            super(cause);
-        }
+  class ConnectorConfigurationException extends RuntimeException {
+    ConnectorConfigurationException(final Throwable cause) {
+      super(cause);
     }
-
+  }
 }