add benchmark jmh

Author: seko0716

performance-test/pom.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns="http://maven.apache.org/POM/4.0.0"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <parent>
+ <artifactId>kafka-connect-transformers</artifactId>
+ <groupId>seko</groupId>
+ <version>1.0-SNAPSHOT</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+
+ <artifactId>performance-test</artifactId>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.openjdk.jmh</groupId>
+ <artifactId>jmh-core</artifactId>
+ <version>1.21</version>
+ </dependency>
+ <dependency>
+ <groupId>org.openjdk.jmh</groupId>
+ <artifactId>jmh-generator-annprocess</artifactId>
+ <version>1.21</version>
+ </dependency>
+ <dependency>
+ <groupId>seko</groupId>
+ <artifactId>shared</artifactId>
+ <version>1.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>seko</groupId>
+ <artifactId>python-transformer</artifactId>
+ <version>1.0-SNAPSHOT</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>seko</groupId>
+ <artifactId>groovy-transformer</artifactId>
+ <version>1.0-SNAPSHOT</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>seko</groupId>
+ <artifactId>js-transformer</artifactId>
+ <version>1.0-SNAPSHOT</version>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+
+</project>

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

@@ -0,0 +1,60 @@
+package seko.kafka.connect.transformer.jmh.tests;
+
+
+import org.apache.kafka.connect.source.SourceRecord;
+import org.apache.kafka.connect.transforms.util.Requirements;
+import org.openjdk.jmh.annotations.*;
+import seko.kafka.connect.transformer.python.GroovyTransformer;
+import seko.kafka.connect.transformer.python.JavaScriptTransformer;
+import seko.kafka.connect.transformer.python.PythonTransformer;
+import seko.kafka.connect.transformer.script.configs.Configuration;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+@BenchmarkMode(Mode.AverageTime)
+@OutputTimeUnit(TimeUnit.NANOSECONDS)
+@State(Scope.Benchmark)
+@Fork(value = 2, jvmArgs = {"-Xms2G", "-Xmx2G"})
+//@Warmup(iterations = 3)
+//@Measurement(iterations = 8)
+public class TransformersTest {
+ private final PythonTransformer<SourceRecord> pythonTransformer = new PythonTransformer<>();
+ private final GroovyTransformer<SourceRecord> groovyTransformer = new GroovyTransformer<>();
+ private final JavaScriptTransformer<SourceRecord> jsTransformer = new JavaScriptTransformer<>();
+ private Map<String, Object> config;
+ @Param({"10000000"})
+ private int N;
+ private Map<String, Object> event;
+
+ @Setup
+ public void setup() {
+ config = new HashMap<>();
+ config.put(Configuration.KEY_SCRIPT_CONFIG, "source['qweqweq'] = 12312312; source");
+ config.put(Configuration.VALUE_SCRIPT_CONFIG, "source['qweqweq'] = 12312312; source");
+ pythonTransformer.configure(config);
+ groovyTransformer.configure(config);
+ jsTransformer.configure(config);
+ event = new HashMap<>();
+ event.put("created_when", "2019-05-31T00:17:00.188Z");
+ }
+
+ @Benchmark
+ public void jsTransformer() {
+ SourceRecord transformed = jsTransformer.apply(new SourceRecord(null, null, "topic", 0, null, event));
+ Map<String, Object> stringObjectMap = Requirements.requireMapOrNull(transformed.value(), "");
+ }
+
+ @Benchmark
+ public void groovyTransformer() {
+ SourceRecord transformed = groovyTransformer.apply(new SourceRecord(null, null, "topic", 0, null, event));
+ Map<String, Object> stringObjectMap = Requirements.requireMapOrNull(transformed.value(), "");
+ }
+
+ @Benchmark
+ public void pythonTransformer() {
+ SourceRecord transformed = pythonTransformer.apply(new SourceRecord(null, null, "topic", 0, null, event));
+ Map<String, Object> stringObjectMap = Requirements.requireMapOrNull(transformed.value(), "");
+ }
+}

pom.xml

@@ -13,6 +13,7 @@
  <module>python-transformer</module>
  <module>js-transformer</module>
  <module>shared</module>
+ <module>performance-test</module>
  </modules>