我无法使用 Kafka 弹性搜索连接器将 kafka 连接到弹性搜索答案

【问题标题】：I am not able to connect kafka to elastic search using Kafka elasticsearch connector我无法使用 Kafka 弹性搜索连接器将 kafka 连接到弹性搜索
【发布时间】：2017-07-21 20:13:31
【问题描述】：

我正在关注这篇文章 https://sematext.com/blog/2017/03/06/kafka-connect-elasticsearch-how-to/

我收到错误

Caused by: org.apache.kafka.connect.errors.ConnectException: 
Failed to find any class that implements Connector and which name matches io.confluent.connect.elasticsearch.ElasticsearchSinkConnector  [...]

【问题讨论】：

你是否在构建后将连接器复制到 Kafka 的 libs 目录？如果由于某种原因 ElasticsearchSinkConnector 不在 Kafka Connect 的类路径中，您会看到此错误。

标签： elasticsearch apache-kafka apache-kafka-connect

【解决方案1】：

正如 Sönke 在 cmets 中所说，这是一个类路径问题。您可以通过使用 Confluent Open Source 发行版来避开这一点，该发行版自动包含 Kafka Connect Elasticsearch 插件，并且路径已经到位。

【讨论】：