Minor cleanup

Author: rayokota

src/main/java/io/kcache/kwack/KwackConfig.java

@@ -17,7 +17,6 @@
 package io.kcache.kwack;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.MappingIterator;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.ObjectReader;
@@ -26,12 +25,10 @@
 import com.fasterxml.jackson.dataformat.csv.CsvMapper;
 import com.fasterxml.jackson.dataformat.csv.CsvParser;
 import com.fasterxml.jackson.dataformat.csv.CsvSchema;
-import io.confluent.kafka.schemaregistry.client.rest.entities.SchemaReference;
 import io.kcache.KafkaCacheConfig;
 import io.kcache.kwack.util.Jackson;
 import java.nio.file.Files;
 import java.nio.file.Paths;
-import java.util.Collections;
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.common.config.ConfigDef.Importance;
 import org.apache.kafka.common.config.ConfigDef.Type;

src/main/java/io/kcache/kwack/KwackEngine.java

@@ -873,9 +873,7 @@ public void handleUpdate(Bytes key, Bytes value, Bytes oldValue,
 
         @Override
         public void endBatch(int count) {
-            stmts.entrySet().forEach(entry -> {
-                String sql = entry.getKey();
-                PreparedStatement stmt = entry.getValue();
+            stmts.forEach((sql, stmt) -> {
                 try {
                     stmt.executeBatch();
                     stmt.close();

src/main/java/io/kcache/kwack/KwackMain.java

@@ -21,8 +21,6 @@
 
 import java.io.File;
 import java.io.IOException;
-import java.net.URI;
-import java.net.URISyntaxException;
 import java.net.URL;
 import java.util.Enumeration;
 import java.util.HashMap;

src/main/java/io/kcache/kwack/sqlline/KwackPromptHandler.java

@@ -1,10 +1,7 @@
 package io.kcache.kwack.sqlline;
 
-import sqlline.Application;
-import sqlline.BuiltInProperty;
 import sqlline.PromptHandler;
 import sqlline.SqlLine;
-import sqlline.SqlLineOpts;
 
 public class KwackPromptHandler extends PromptHandler {
 
@@ -14,7 +11,7 @@ public KwackPromptHandler(SqlLine sqlline) {
 
     @Override
     protected String getDefaultPrompt(int connectionIndex, String url, String defaultPrompt) {
-        if (url != null && url.length() != 0) {
+        if (url != null && !url.isEmpty()) {
             if (url.contains(";")) {
                 url = url.substring(0, url.indexOf(";"));
             }

src/main/java/io/kcache/kwack/transformer/protobuf/ProtobufTransformer.java

@@ -7,7 +7,6 @@
 import com.google.protobuf.Descriptors.EnumDescriptor;
 import com.google.protobuf.Descriptors.EnumValueDescriptor;
 import com.google.protobuf.Descriptors.FieldDescriptor;
-import com.google.protobuf.Descriptors.FileDescriptor;
 import com.google.protobuf.Descriptors.OneofDescriptor;
 import com.google.protobuf.Message;
 import io.confluent.kafka.schemaregistry.ParsedSchema;