Merge pull request #150 from marklogic/feature/sonar-fixes

Fixed two sonar code smells

Author: rjrudin

src/main/java/com/marklogic/kafka/connect/sink/RunFlowWriteBatchListener.java

@@ -63,8 +63,8 @@ public RunFlowWriteBatchListener(String flowName, List<String> steps, DatabaseCl
     public void processEvent(WriteBatch batch) {
         FlowInputs inputs = buildFlowInputs(batch);
 
-        // TODO When this was originally created for DHF 5.2, basic/digest auth were required. Need to support all
-        // auth techniques.
+        // Current plan for 1.9.0 is to support Java Client 6.1.0, at which point we may be able to support any auth
+        // technique here as well.
         FlowRunner flowRunner = new FlowRunnerImpl(HubClient.withHubClientConfig(new HubClientConfig(
             databaseClientConfig.getHost(),
             databaseClientConfig.getUsername(),

src/main/java/com/marklogic/kafka/connect/sink/WriteBatcherSinkTask.java

@@ -1,7 +1,11 @@
 package com.marklogic.kafka.connect.sink;
 
 import com.marklogic.client.DatabaseClient;
-import com.marklogic.client.datamovement.*;
+import com.marklogic.client.datamovement.DataMovementManager;
+import com.marklogic.client.datamovement.WriteBatch;
+import com.marklogic.client.datamovement.WriteBatcher;
+import com.marklogic.client.datamovement.WriteEvent;
+import com.marklogic.client.datamovement.WriteFailureListener;
 import com.marklogic.client.document.ServerTransform;
 import com.marklogic.client.ext.DatabaseClientConfig;
 import com.marklogic.client.ext.DefaultConfiguredDatabaseClientFactory;
@@ -16,7 +20,6 @@
 import org.apache.kafka.connect.runtime.InternalSinkRecord;
 import org.apache.kafka.connect.sink.ErrantRecordReporter;
 import org.apache.kafka.connect.sink.SinkRecord;
-import org.slf4j.LoggerFactory;
 import org.springframework.util.StringUtils;
 
 import java.io.IOException;
@@ -28,7 +31,7 @@
 import java.util.Optional;
 import java.util.function.BiConsumer;
 
-import static com.marklogic.kafka.connect.sink.AbstractSinkTask.*;
+import static com.marklogic.kafka.connect.sink.AbstractSinkTask.MARKLOGIC_WRITE_FAILURE;
 
 /**
  * Uses MarkLogic's Data Movement SDK (DMSDK) to write data to MarkLogic.