amazon-s3 - Kafka Confluent S3 连接器 "Failed to find class"

Question

我正在尝试一个简单的快速入门示例，我得到:

Caused by: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches io.confluent.connect.s3.S3SinkConnector, available connectors are: io.confluent.connect.jdbc.JdbcSinkConnector, io.confluent.connect.jdbc.JdbcSourceConnector, org.apache.kafka.connect.tools.MockSinkConnector, org.apache.kafka.connect.file.FileStreamSourceConnector, org.apache.kafka.connect.sink.SinkConnector, io.confluent.connect.elasticsearch.ElasticsearchSinkConnector, org.apache.kafka.connect.tools.MockConnector, io.confluent.connect.hdfs.HdfsSinkConnector, org.apache.kafka.connect.file.FileStreamSinkConnector, org.apache.kafka.connect.tools.VerifiableSourceConnector, org.apache.kafka.connect.tools.VerifiableSinkConnector, org.apache.kafka.connect.tools.SchemaSourceConnector, org.apache.kafka.connect.source.SourceConnector, org.apache.kafka.connect.tools.MockSourceConnector, io.confluent.connect.hdfs.tools.SchemaSourceConnector

这是一个全新的 VM，运行通过 Debian apt 包安装的最新 Confluent Platform 3.2.0。我可以看到它肯定在运行 CP 3.2.0。为什么 S3 连接器类不可用？

不确定这是否相关，但如果我这样做:

ls -l /etc/ | grep kafka
drwxr-xr-x 2 root root           4096 Apr  5 04:41 kafka
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-connect-elasticsearch
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-connect-hdfs
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-connect-jdbc
drwxr-xr-x 2 root root           4096 Apr  5 04:39 kafka-rest

文档引用了安装中显然不存在的 kafka-connect-s3 目录。

我正在使用 Confluent Platform 的开源变体，但根据 https://www.confluent.io/product/compare/ ，开源版本包括 Confluent Amazon S3 Connect 连接器。

Answer 1

这是 3.2.0 中的一个打包错误，在最新的 Confluent 版本中已修复，截至今天(2017 年 5 月 17 日)为 3.2.1

在 3.2.1 版本中还修复了 S3 连接器的错误，因此无论如何最好使用该版本。