我正在关注这篇文章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 [...]
正如Sönke在评论中所说，这是一个类路径问题。您可以通过使用包含Kafka Connect Elasticsearch插件的ConFluent开源发行版自动解决这个问题，并且路径已经到位。
