add fail test

Author: seko0716

README.md

@@ -49,7 +49,7 @@ supported languages:
 ```json
 {
  "transforms": "pythonTransform",
- "transforms.groovyTransform.type": "seko.kafka.connect.transformer.python.ScriptEngineTransformer",
+ "transforms.groovyTransform.type": "seko.kafka.connect.transformer.script.ScriptEngineTransformer",
  "transforms.groovyTransform.key.script": "def keyTransform(source): source['qweqweq'] = 12312312; return source",
  "transforms.groovyTransform.value.script": "def valueTransform(source): source['qweqweq'] = 12312312; return source"
 }

performance-test/src/test/java/seko/kafka/connect/transformer/jmh/tests/TransformersTest.java

@@ -6,7 +6,7 @@
 import org.junit.Assert;
 import org.openjdk.jmh.annotations.*;
 import seko.kafka.connect.transformer.groovy.GroovyTransformer;
-import seko.kafka.connect.transformer.python.ScriptEngineTransformer;
+import seko.kafka.connect.transformer.script.ScriptEngineTransformer;
 import seko.kafka.connect.transformer.script.configs.Configuration;
 
 import java.util.HashMap;

…rmer/python/ScriptEngineTransformer.java …rmer/script/ScriptEngineTransformer.javascript-engine-tansformer/src/main/java/seko/kafka/connect/transformer/python/ScriptEngineTransformer.java renamed to script-engine-tansformer/src/main/java/seko/kafka/connect/transformer/script/ScriptEngineTransformer.java script-engine-tansformer/src/main/java/seko/kafka/connect/transformer/python/ScriptEngineTransformer.java renamed to script-engine-tansformer/src/main/java/seko/kafka/connect/transformer/script/ScriptEngineTransformer.java

@@ -1,4 +1,4 @@
-package seko.kafka.connect.transformer.python;
+package seko.kafka.connect.transformer.script;
 
 import jdk.nashorn.api.scripting.NashornScriptEngineFactory;
 import org.apache.kafka.common.config.ConfigDef;
@@ -133,8 +133,7 @@ private ScriptEngine getScript(String script) {
  scriptEngine.eval(script);
  return scriptEngine;
  } catch (ScriptException e) {
- e.printStackTrace();
- return null;
+ throw new ConfigException("Invalid script");
  }
  }
 }

…/python/ScriptEngineTransformerTest.java …/script/ScriptEngineTransformerTest.javascript-engine-tansformer/src/test/java/seko/kafka/connect/transformer/python/ScriptEngineTransformerTest.java renamed to script-engine-tansformer/src/test/java/seko/kafka/connect/transformer/script/ScriptEngineTransformerTest.java script-engine-tansformer/src/test/java/seko/kafka/connect/transformer/python/ScriptEngineTransformerTest.java renamed to script-engine-tansformer/src/test/java/seko/kafka/connect/transformer/script/ScriptEngineTransformerTest.java

@@ -1,5 +1,6 @@
-package seko.kafka.connect.transformer.python;
+package seko.kafka.connect.transformer.script;
 
+import org.apache.kafka.common.config.ConfigException;
 import org.apache.kafka.connect.source.SourceRecord;
 import org.apache.kafka.connect.transforms.util.Requirements;
 import org.junit.Assert;
@@ -79,6 +80,35 @@ public void applyWithoutSchemaRuby() {
  Assert.assertEquals("key___123", transformed.key());
  }
 
+
+ @Test(expected = ConfigException.class)
+ public void applyWithoutSchemaJsConfigFail() {
+ config.put(Configuration.SCRIP_ENGINE_NAME, "JavaScript");
+ config.put(Configuration.KEY_SCRIPT_CONFIG, "java.lang.System.exit(9);function keyTransform(source){ return source + '123'; }");
+ config.put(Configuration.VALUE_SCRIPT_CONFIG, "function valueTransform(source){ source.qweqweq = 12312312; return source;}");
+ transformer.configure(config);
+
+ SourceRecord transformed = transformer.apply(record);
+ Map<String, Object> stringObjectMap = Requirements.requireMapOrNull(transformed.value(), "");
+ Assert.assertEquals(12312312, stringObjectMap.get("qweqweq"));
+ Assert.assertEquals(2, stringObjectMap.size());
+ Assert.assertEquals("key___123", transformed.key());
+ }
+
+ @Test
+ public void applyWithoutSchemaJsFail() {
+ config.put(Configuration.SCRIP_ENGINE_NAME, "JavaScript");
+ config.put(Configuration.KEY_SCRIPT_CONFIG, "function keyTransform(source){ java.lang.System.exit(9); return source + '123'; }");
+ config.put(Configuration.VALUE_SCRIPT_CONFIG, "function valueTransform(source){ source.qweqweq = 12312312; return source;}");
+ transformer.configure(config);
+
+ SourceRecord transformed = transformer.apply(record);
+ Map<String, Object> stringObjectMap = Requirements.requireMapOrNull(transformed.value(), "");
+ Assert.assertEquals(12312312, stringObjectMap.get("qweqweq"));
+ Assert.assertEquals(2, stringObjectMap.size());
+ Assert.assertEquals("key___", transformed.key());
+ }
+
  /*@Test(expected = ConfigException.class)
  public void testSFConfigEmpty() {
  config.put(Configuration.KEY_SCRIPT_CONFIG, "");