diff --git a/pom.xml b/pom.xml index fe7c46c..98dc74f 100644 --- a/pom.xml +++ b/pom.xml @@ -46,6 +46,26 @@ + + org.apache.maven.plugins + maven-shade-plugin + 2.4.3 + + + package + + shade + + + + + + + + + + @@ -53,7 +73,7 @@ org.apache.kafka connect-api - 0.9.0.0 + 0.10.0.0 compile @@ -70,7 +90,7 @@ org.elasticsearch elasticsearch - 2.0.0 + 2.3.3 \ No newline at end of file diff --git a/src/main/java/org/apache/kafka/connect/elasticsearchschema/ElasticsearchSinkConnector.java b/src/main/java/org/apache/kafka/connect/elasticsearchschema/ElasticsearchSinkConnector.java index 96441d2..30efbff 100644 --- a/src/main/java/org/apache/kafka/connect/elasticsearchschema/ElasticsearchSinkConnector.java +++ b/src/main/java/org/apache/kafka/connect/elasticsearchschema/ElasticsearchSinkConnector.java @@ -1,5 +1,6 @@ package org.apache.kafka.connect.elasticsearchschema; +import org.apache.kafka.common.config.ConfigDef; import org.apache.kafka.common.utils.AppInfoParser; import org.apache.kafka.connect.connector.Task; import org.apache.kafka.connect.errors.ConnectException; @@ -128,4 +129,10 @@ public List> taskConfigs(int maxTasks) { public void stop() { // Nothing to do } + + @Override + public ConfigDef config() { + return null; + } + }