Merge pull request #44 from meghanayofficial/feature/Fix-Lexer-issue-…

…for-protobuf

Fix Lexer issue for Format type Protobuf

src/main/antlr/ConnectorLexer.g4

@@ -130,7 +130,7 @@ WITHUNWRAP
     ;
 
 FORMAT
-    : 'avro'|'AVRO'|'text'|'TEXT'|'binary'|'BINARY'|'json'|'JSON'|'object'|'OBJECT'|'map'|'MAP'
+    : 'avro'|'AVRO'|'text'|'TEXT'|'binary'|'BINARY'|'json'|'JSON'|'object'|'OBJECT'|'map'|'MAP'|'protobuf'|'PROTOBUF'
     ;
 
 PROJECTTO

src/test/java/com/datamountaineer/kcql/KcqlTest.java

@@ -801,6 +801,10 @@ public void handleStoredAs() {
     String syntax4 = String.format("INSERT INTO %s SELECT * FROM %s WITHFORMAT object", table, topic);
     Kcql c4 = Kcql.parse(syntax4);
     assertEquals(c4.getFormatType().toString(), "OBJECT");
+
+    String syntax5 = String.format("INSERT INTO %s SELECT * FROM %s WITHFORMAT protobuf", table, topic);
+    Kcql c5 = Kcql.parse(syntax5);
+    assertEquals(c5.getFormatType().toString(), "PROTOBUF");
   }
 
   @Test(expected = IllegalArgumentException.class)