feat(expression): migrate ScEL to Antlr4 grammar (#60)

This commit add a new maven module dedicated for
Simple Connect Expression Language (ScEL).

ScEL has been refactorted to be compiled based Lexer/Parser
generated through Antlr4 grammar.

Resolves: GH-60

Author: fhussonnois

checkstyle/suppressions.xml

@@ -66,4 +66,6 @@
 
     <suppress checks="Header" files="log4j.properties"/>
 
+    <suppress checks="[a-zA-Z0-9]*" files="src/main/java/io/streamthoughts/kafka/connect/filepulse/expression/parser/antlr4/*"/>
+
 </suppressions>

config/connect-file-pulse-example-override-topic-and-key.json

@@ -2,10 +2,10 @@
   "config": {
     "connector.class": "io.streamthoughts.kafka.connect.filepulse.source.FilePulseSourceConnector",
     "filters": "ParseDelimitedRow, SetTopic, SetKey",
-    "filters.SetTopic.value": "{{ replace_all(lowercase(type), \\s,-) }}",
+    "filters.SetTopic.value": "replace_all(lowercase($.type), '\\s','-')",
     "filters.SetTopic.field": "$topic",
     "filters.SetTopic.type": "io.streamthoughts.kafka.connect.filepulse.filter.AppendFilter",
-    "filters.SetKey.value": "{{ lowercase(artist) }}-{{ lowercase(title) }}",
+    "filters.SetKey.value": "{{ lowercase($.artist) }}-{{ lowercase($.title) }}",
     "filters.SetKey.field": "$key",
     "filters.SetKey.type": "io.streamthoughts.kafka.connect.filepulse.filter.AppendFilter",
     "filters.ParseDelimitedRow.extractColumnName": "headers",

config/connect-file-pulse-quickstart-csv.json

@@ -2,7 +2,7 @@
   "config": {
     "connector.class": "io.streamthoughts.kafka.connect.filepulse.source.FilePulseSourceConnector",
     "filters": "ParseDelimitedRow, Drop",
-    "filters.Drop.if": "{{ equals(artist,U2) }}",
+    "filters.Drop.if": "{{ equals($value.artist, 'U2') }}",
     "filters.Drop.invert": "true",
     "filters.Drop.type": "io.streamthoughts.kafka.connect.filepulse.filter.DropFilter",
     "filters.ParseDelimitedRow.extractColumnName": "headers",

connect-file-pulse-api/pom.xml

@@ -95,26 +95,25 @@
     </build>
 
     <dependencies>
-
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka-clients</artifactId>
         </dependency>
-
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>connect-api</artifactId>
         </dependency>
-
         <dependency>
             <groupId>com.jsoniter</groupId>
             <artifactId>jsoniter</artifactId>
         </dependency>
-
         <dependency>
             <groupId>commons-io</groupId>
             <artifactId>commons-io</artifactId>
-            <version>2.5</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
         </dependency>
 
         <!-- START test dependencies-->