Remove unwanted code and clean the code

src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/KustoSinkConfig.java

@@ -120,12 +120,10 @@ public class KustoSinkConfig extends AbstractConfig {
       final String connectionGroupName = "Connection";
       final String writeGroupName = "Writes";
       final String errorAndRetriesGroupName = "Error Handling and Retries";
-      final String formatGroupName = "formatter";
 
       int connectionGroupOrder = 0;
       int writeGroupOrder = 0;
       int errorAndRetriesGroupOrder = 0;
-      int formatGroupNameOrder =0;
 
       //TODO: Add display name, validators, recommenders to configs.
         return new ConfigDef()

src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/TopicPartitionWriter.java

@@ -49,7 +49,7 @@ class TopicPartitionWriter {
         this.eventDataCompression = ingestionProps.eventDataCompression;
         this.currentRetries = defaultRetriesCount;
         this.reentrantReadWriteLock = new ReentrantReadWriteLock(true);
-        this.config=config;
+        this.config = config;
     }
 
     String handleRollFile(SourceFile fileDescriptor) {
@@ -137,7 +137,7 @@ class TopicPartitionWriter {
                 shouldCompressData,
                 reentrantReadWriteLock,
                 config,
-            ingestionProps);
+                ingestionProps);
     }
 
     void close() {

src/test/java/com/microsoft/azure/kusto/kafka/connect/sink/E2ETest.java

@@ -19,7 +19,11 @@ import java.io.FileInputStream;
 import java.io.IOException;
 import java.net.URISyntaxException;
 import java.nio.file.Paths;
-import java.util.*;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.UUID;
 import java.util.logging.Logger;
 
 public class E2ETest {