Spotless: Automatic code format updates

Author: rozza

src/main/java/com/mongodb/kafka/connect/sink/MongoSinkTopicConfig.java

@@ -389,12 +389,19 @@ public String getTopic() {
   public boolean logErrors() {
     return !tolerateErrors()
         || ConfigHelper.getOverrideOrFallback(
-            this, AbstractConfig::getBoolean, OVERRIDE_ERRORS_LOG_ENABLE_CONFIG, ERRORS_LOG_ENABLE_CONFIG);
+            this,
+            AbstractConfig::getBoolean,
+            OVERRIDE_ERRORS_LOG_ENABLE_CONFIG,
+            ERRORS_LOG_ENABLE_CONFIG);
   }
 
   public boolean tolerateErrors() {
-    String errorsTolerance = ConfigHelper.getOverrideOrFallback(
-            this, AbstractConfig::getString, OVERRIDE_ERRORS_TOLERANCE_CONFIG, ERRORS_TOLERANCE_CONFIG);
+    String errorsTolerance =
+        ConfigHelper.getOverrideOrFallback(
+            this,
+            AbstractConfig::getString,
+            OVERRIDE_ERRORS_TOLERANCE_CONFIG,
+            ERRORS_TOLERANCE_CONFIG);
     return ErrorTolerance.valueOf(errorsTolerance.toUpperCase()).equals(ErrorTolerance.ALL);
   }
 

src/main/java/com/mongodb/kafka/connect/source/MongoSourceConfig.java

@@ -439,21 +439,30 @@ public JsonWriterSettings getJsonWriterSettings() {
 
   @SuppressWarnings("deprecated")
   public boolean tolerateErrors() {
-    String errorsTolerance = ConfigHelper.getOverrideOrFallback(
-            this, AbstractConfig::getString, OVERRIDE_ERRORS_TOLERANCE_CONFIG, ERRORS_TOLERANCE_CONFIG);
+    String errorsTolerance =
+        ConfigHelper.getOverrideOrFallback(
+            this,
+            AbstractConfig::getString,
+            OVERRIDE_ERRORS_TOLERANCE_CONFIG,
+            ERRORS_TOLERANCE_CONFIG);
     return ErrorTolerance.valueOf(errorsTolerance.toUpperCase()).equals(ErrorTolerance.ALL);
   }
 
   public boolean logErrors() {
     return !tolerateErrors()
         || ConfigHelper.getOverrideOrFallback(
-            this, AbstractConfig::getBoolean, OVERRIDE_ERRORS_LOG_ENABLE_CONFIG, ERRORS_LOG_ENABLE_CONFIG);
+            this,
+            AbstractConfig::getBoolean,
+            OVERRIDE_ERRORS_LOG_ENABLE_CONFIG,
+            ERRORS_LOG_ENABLE_CONFIG);
   }
 
   public String getDlqTopic() {
     return ConfigHelper.getOverrideOrFallback(
-        this, AbstractConfig::getString,
-        OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG, ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG);
+        this,
+        AbstractConfig::getString,
+        OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
+        ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG);
   }
 
   private <T extends Configurable> T configureInstance(final T instance) {

src/main/java/com/mongodb/kafka/connect/util/ConfigHelper.java

@@ -156,8 +156,10 @@ public static String getOverrideOrDefault(
   }
 
   public static <T> T getOverrideOrFallback(
-      final AbstractConfig config, final BiFunction<AbstractConfig, String, T> getter,
-      final String overrideProperty, final String defaultProperty) {
+      final AbstractConfig config,
+      final BiFunction<AbstractConfig, String, T> getter,
+      final String overrideProperty,
+      final String defaultProperty) {
     String propertyToRead =
         config.originals().containsKey(overrideProperty) ? overrideProperty : defaultProperty;
     return getter.apply(config, propertyToRead);

src/test/java/com/mongodb/kafka/connect/source/MongoSourceConfigTest.java

@@ -375,63 +375,71 @@ void testErrorConfigurations() {
   void testErrorConfigurationOverrides() {
     assertAll(
         "Error configuration overrides",
-        () -> assertTrue(createSourceConfig(OVERRIDE_ERRORS_TOLERANCE_CONFIG, "all").tolerateErrors()),
-        () -> assertFalse(createSourceConfig(OVERRIDE_ERRORS_TOLERANCE_CONFIG, "none").tolerateErrors()),
+        () ->
+            assertTrue(
+                createSourceConfig(OVERRIDE_ERRORS_TOLERANCE_CONFIG, "all").tolerateErrors()),
+        () ->
+            assertFalse(
+                createSourceConfig(OVERRIDE_ERRORS_TOLERANCE_CONFIG, "none").tolerateErrors()),
         () ->
             assertFalse(
                 createSourceConfig(
-                    format(
-                        "{'%s': '%s', '%s': '%s'}",
-                        ERRORS_TOLERANCE_CONFIG,
-                        "all",
-                        OVERRIDE_ERRORS_TOLERANCE_CONFIG,
-                        "none"))
-                .tolerateErrors()),
+                        format(
+                            "{'%s': '%s', '%s': '%s'}",
+                            ERRORS_TOLERANCE_CONFIG,
+                            "all",
+                            OVERRIDE_ERRORS_TOLERANCE_CONFIG,
+                            "none"))
+                    .tolerateErrors()),
         () ->
             assertTrue(
                 createSourceConfig(
-                    format(
-                        "{'%s': '%s', '%s': '%s'}",
-                        ERRORS_TOLERANCE_CONFIG,
-                        "none",
-                        OVERRIDE_ERRORS_TOLERANCE_CONFIG,
-                        "all"))
+                        format(
+                            "{'%s': '%s', '%s': '%s'}",
+                            ERRORS_TOLERANCE_CONFIG,
+                            "none",
+                            OVERRIDE_ERRORS_TOLERANCE_CONFIG,
+                            "all"))
                     .tolerateErrors()),
         () -> assertTrue(createSourceConfig(OVERRIDE_ERRORS_LOG_ENABLE_CONFIG, "true").logErrors()),
-        () -> assertTrue(
+        () ->
+            assertTrue(
                 createSourceConfig(
-                    format(
-                        "{'%s': '%s', '%s': '%s'}",
-                        ERRORS_LOG_ENABLE_CONFIG,
-                        "false",
-                        OVERRIDE_ERRORS_LOG_ENABLE_CONFIG,
-                        "true"))
+                        format(
+                            "{'%s': '%s', '%s': '%s'}",
+                            ERRORS_LOG_ENABLE_CONFIG,
+                            "false",
+                            OVERRIDE_ERRORS_LOG_ENABLE_CONFIG,
+                            "true"))
                     .logErrors()),
         () -> assertEquals("", createSourceConfig().getDlqTopic()),
-        () -> assertEquals("dlq", createSourceConfig(OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG, "dlq").getDlqTopic()),
+        () ->
+            assertEquals(
+                "dlq",
+                createSourceConfig(OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG, "dlq")
+                    .getDlqTopic()),
         () ->
             assertEquals(
                 "dlq",
                 createSourceConfig(
-                    format(
-                        "{'%s': '%s', '%s': '%s'}",
-                        ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
-                        "qld",
-                        OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
-                        "dlq"))
+                        format(
+                            "{'%s': '%s', '%s': '%s'}",
+                            ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
+                            "qld",
+                            OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
+                            "dlq"))
                     .getDlqTopic()),
         () ->
             assertEquals(
                 "",
                 createSourceConfig(
-                    format(
-                        "{'%s': '%s', '%s': '%s'}",
-                        ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
-                        "qld",
-                        OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
-                        ""))
-                    .getDlqTopic())
-    );
+                        format(
+                            "{'%s': '%s', '%s': '%s'}",
+                            ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
+                            "qld",
+                            OVERRIDE_ERRORS_DEAD_LETTER_QUEUE_TOPIC_NAME_CONFIG,
+                            ""))
+                    .getDlqTopic()));
   }
 
   @Test