Kafka connect confluent elasticsearch sink (no class found error)
<p>I am very new to Kafka connect. I want to push my messages from Kafka topic to elasticsearch. After following the available documentation.. I downloaded and compiled elastic search sink from release tar.zip (<a href="https://github.com/confluentinc/kafka-connect-elasticsearch/releases" rel="nofollow noreferrer">https://github.com/confluentinc/kafka-connect-elasticsearch/releases</a>)</p>

<p>I added the elastic search properties file and included the above jar in classpath. When I run kafka connect in standalone mode I get this error</p>

<blockquote>
  <p>./usr/bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties etc/kafka-connect-elasticsearch/quickstart-elasticsearch.properties</p>
</blockquote>

<pre><code>[2016-11-13 00:05:38,768] ERROR Task elasticsearch-sink-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142) java.lang.NoClassDefFoundError:io/searchbox/client/JestClientFactory
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:81)
at io.confluent.connect.elasticsearch.ElasticsearchSinkTask.start(ElasticsearchSinkTask.java:52)
at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:207)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:139)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
at o
</code></pre>

<blockquote>
  <p>NoClassDefFoundError:io/searchbox/client/JestClientFactory</p>
</blockquote>

<p>I checkedthe pom.xml and it has Jest client dependency defined correctly. Am I missing anything?</p>

<p>Any pointers would be really appreciated.</p>

<p>Thanks,
Rajesh</p>