fix(api): fix regression with ConnectSchemaMapper (#95)

Resolves: #95

Author: fhussonnois

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/source/internal/ConnectSchemaMapper.java

@@ -39,6 +39,7 @@
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Map;
+import java.util.function.Predicate;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
@@ -52,6 +53,7 @@ public class ConnectSchemaMapper implements SchemaMapper<Schema>, SchemaMapperWi
     static String normalizeSchemaName(final String name) {
         return Arrays
             .stream(REGEX.split(name))
+            .filter(s -> !s.isEmpty())
             .map(it -> it.substring(0, 1).toUpperCase() + it.substring(1))
             .collect(Collectors.joining());
     }

connect-file-pulse-api/src/test/java/io/streamthoughts/kafka/connect/filepulse/source/internal/ConnectSchemaMapperTest.java

@@ -139,4 +139,12 @@ public void shouldMapGivenTypeStructWithNullValue() {
         Assert.assertNull(connectStruct.schema().field("field2"));
     }
 
+    @Test
+    public void test_normalize_schema_name() {
+        Assert.assertEquals("Foo", ConnectSchemaMapper.normalizeSchemaName("foo"));
+        Assert.assertEquals("FooBar", ConnectSchemaMapper.normalizeSchemaName("foo_bar"));
+        Assert.assertEquals("FooBar", ConnectSchemaMapper.normalizeSchemaName("foo.bar"));
+        Assert.assertEquals("FooBar", ConnectSchemaMapper.normalizeSchemaName("_foo_bar"));
+    }
+
 }