fixes #199 add pre-commit hook and apply it

.gitignore

@@ -31,4 +31,4 @@ exec-develop-build/bin/
 exec-regex-replace/bin/
 exec-release-docker/bin/
 exec-release-maven/bin/
-exec-version-upgrade/bin/
+exec-version-upgrade/bin/

.pre-commit-config.yaml

@@ -0,0 +1,14 @@
+repos:
+-   repo: https://github.com/pre-commit/pre-commit-hooks
+    rev: v3.2.0
+    hooks:
+    -   id: trailing-whitespace
+    -   id: end-of-file-fixer
+    -   id: check-yaml
+    -   id: check-added-large-files
+-   repo: https://github.com/networknt/pre-commit-hook-keyword
+    rev: f17c4de14fc24420f6768c19cad06ba03af06d86
+    hooks:
+    -   id: keywordscan
+        args: ["--keywords=c3VubGlmZQ==,Y2liYw==,c3VuIGxpZmU="]
+        types: ["text"]

kafka-common/src/main/java/com/networknt/kafka/common/AvroSchemaUtils.java

@@ -78,4 +78,4 @@ public static Schema getSchema(Object object) {
               + "Float, Double, String, byte[] and IndexedRecord");
     }
   }
-}
+}

kafka-common/src/main/java/com/networknt/kafka/common/CircularFifoQueue.java

@@ -403,4 +403,4 @@ public void remove() {
         };
     }
 
-}
+}

kafka-common/src/main/java/com/networknt/kafka/common/EventId.java

@@ -478,13 +478,3 @@ public EventId build() {
     }
   }
 }
-
-
-
-
-
-
-
-
-
-

kafka-common/src/main/java/com/networknt/kafka/common/JsonPOJOSerializer.java

@@ -34,4 +34,4 @@ public byte[] serialize(String topic, T data) {
     public void close() {
     }
 
-}
+}

kafka-common/src/test/java/com/networknt/kafka/common/CircularFifoQueueTest.java

@@ -289,4 +289,4 @@ public void testRepeatedSerialization() throws Exception {
         assertEquals(true, b3.contains("c"));
     }
 
-}
+}

kafka-common/src/test/resources/config/kafka-consumer.yml

@@ -99,4 +99,3 @@ iteratorBackoffMs: ${kafka-consumer.iteratorBackoffMs:50}
 #keep alive time out occurs and sidecar consumer does not move forward. Hence we are adding this property so that we can explicitly close the connection
 #when we receive the response and not wait for FinAck.
 backendConnectionReset: ${kafka-consumer.backendConnectionReset:false}
-

kafka-common/src/test/resources/config/kafka-ksqldb.yml

@@ -27,4 +27,4 @@ properties:
 # Backend API host
 backendUrl: ${kafka-ksqldb.backendUrl:https://localhost:8080}
 # Backend API path
-backendPath: ${kafka-ksqldb.backendPath:/kafka/ksqldb}
+backendPath: ${kafka-ksqldb.backendPath:/kafka/ksqldb}

kafka-consumer/src/main/java/com/networknt/kafka/consumer/ConsumerInstanceId.java

@@ -56,4 +56,3 @@ public String toString() {
            + '}';
   }
 }
-

kafka-consumer/src/main/java/com/networknt/kafka/consumer/KafkaConsumerState.java

@@ -597,4 +597,3 @@ protected Map<String, String> convertHeaders(Headers headers) {
     return headerMap;
   }
 }
-

kafka-entity/src/main/java/com/networknt/kafka/entity/KsqlDbPullQueryRequest.java

@@ -8,14 +8,14 @@
 
 public class KsqlDbPullQueryRequest  {
 
-    
-    
+
+
     public enum OffsetEnum {
-        
+
         EARLIEST ("earliest"),
-        
+
         LATEST ("latest");
-        
+
 
         private final String value;
 

kafka-entity/src/main/java/com/networknt/kafka/entity/StateStoreValue.java

@@ -49,6 +49,3 @@ default Headers getHeaders() {
         return headers;
     }
 }
-
-
-

kafka-entity/src/main/java/com/networknt/kafka/entity/TopicPartition.java

@@ -25,7 +25,7 @@ public final class TopicPartition {
   private final String topic;
 
   private final Integer partition;
-    
+
   public TopicPartition(
       @JsonProperty("topic") String topic,
       @JsonProperty("partition") Integer partition

kafka-entity/src/test/resources/config/kafka-producer.yml

@@ -52,4 +52,4 @@ retries: ${kafka-producer.retries:0}
 # The maximum number of unacknowledged requests the client will send on a single connection before blocking. Note that if
 # this setting is set to be greater than 1 and there are failed sends, there is a risk of message re-ordering due to retries
 # (i.e., if retries are enabled).
-maxInFlightRequestsPerConnection: ${kafka-producer.maxInFlightRequestsPerConnection:5}
+maxInFlightRequestsPerConnection: ${kafka-producer.maxInFlightRequestsPerConnection:5}

kafka-entity/src/test/resources/config/kafka-streams.yml

@@ -4,4 +4,4 @@ bootstrapServers: localhost:9092
 processingGuarantee: exactly_once
 replicationFactor: 3
 # Only set to true right after the streams reset.
-cleanUp: false
+cleanUp: false

kafka-producer/src/main/java/com/networknt/kafka/producer/CompletableFutures.java

@@ -88,4 +88,3 @@ public static <T, E extends Throwable> CompletableFuture<T> catchingCompose(
                 .thenCompose(wrapped -> wrapped);
     }
 }
-