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

Question

我正在关注这篇文章 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  [...]

Answer 1

正如Sönke在评论中所说，这是一个类路径问题。你可以通过使用Confluent开源发行版来回避这个问题，该发行版包括Kafka Connect Elasticsearch插件，自动包含已经到位的路径。