java - Kafka连接confluent elasticsearch sink(找不到类报错)

Question

我对 Kafka connect 很陌生。我想将我的消息从 Kafka 主题推送到 elasticsearch。在遵循可用文档之后..我从发布的 tar.zip ( https://github.com/confluentinc/kafka-connect-elasticsearch/releases ) 下载并编译了 Elasticsearch 接收器

我添加了 Elasticsearch 属性文件并将上述 jar 包含在类路径中。当我在独立模式下运行 kafka connect 时出现此错误

./usr/bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties etc/kafka-connect-elasticsearch/quickstart-elasticsearch.properties

[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

NoClassDefFoundError:io/searchbox/client/JestClientFactory

我检查了 pom.xml，它正确定义了 Jest 客户端依赖项。我错过了什么吗？

如有任何指点，我们将不胜感激。

谢谢，拉杰什

Answer 1

类路径中确实缺少依赖项之一。 Github 发布页面上的包不包含依赖项。

我建议使用 Confluent Open Source distribution并关注 quickstart .